Skip to content
Snippets Groups Projects
Commit c7ed4ffb authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

Task #8887: typo's

parent 490ea5a2
Branches
No related tags found
No related merge requests found
...@@ -830,7 +830,7 @@ class RADatabase: ...@@ -830,7 +830,7 @@ class RADatabase:
self._executeQuery(query, values) self._executeQuery(query, values)
if validate: if validate:
self.validateResourceClaimsStatus([self.getResourceClaims(resource_claim_ids)], commit=False) self.validateResourceClaimsStatus(self.getResourceClaims(resource_claim_ids), commit=False)
self.validateResourceClaimsStatusForMovedClaims(claimsBeforeUpdate, commit=False) self.validateResourceClaimsStatusForMovedClaims(claimsBeforeUpdate, commit=False)
if commit: if commit:
...@@ -895,11 +895,6 @@ class RADatabase: ...@@ -895,11 +895,6 @@ class RADatabase:
return self.validateResourceClaimsStatus(claims, commit) return self.validateResourceClaimsStatus(claims, commit)
def validateResourceClaimsStatus(self, claims, commit=True): def validateResourceClaimsStatus(self, claims, commit=True):
# cache status_id's for conflift and claimed
claimsStatuses = self.getResourceClaimStatuses()
conflistStatusId = next(cs['id'] for cs in claimsStatuses if cs['name'] == 'conflict')
claimedStatusId = next(cs['id'] for cs in claimsStatuses if cs['name'] == 'claimed')
resource_ids = [c['resource_id'] for c in claims] resource_ids = [c['resource_id'] for c in claims]
task_ids = list(set(c['task_id'] for c in claims)) task_ids = list(set(c['task_id'] for c in claims))
exclude_task_ids = [-t for t in task_ids] exclude_task_ids = [-t for t in task_ids]
...@@ -908,6 +903,11 @@ class RADatabase: ...@@ -908,6 +903,11 @@ class RADatabase:
logger.info("validating status of %d resource claim(s) for task_id(s) %s" % (len(claims), to_csv_string(task_ids))) logger.info("validating status of %d resource claim(s) for task_id(s) %s" % (len(claims), to_csv_string(task_ids)))
# cache status_id's for conflift and claimed
claimsStatuses = self.getResourceClaimStatuses()
conflistStatusId = next(cs['id'] for cs in claimsStatuses if cs['name'] == 'conflict')
claimedStatusId = next(cs['id'] for cs in claimsStatuses if cs['name'] == 'claimed')
# get all claims for given resource_ids, within the given timeframe # get all claims for given resource_ids, within the given timeframe
otherClaims = self.getResourceClaims(resource_ids=resource_ids, otherClaims = self.getResourceClaims(resource_ids=resource_ids,
lower_bound=min_starttime, lower_bound=min_starttime,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment