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

Task #9607: filter for cep4 finalized tasks

parent f29188c8
No related branches found
No related tags found
No related merge requests found
...@@ -38,12 +38,15 @@ def updateTaskStorageDetails(task, sqrpc): ...@@ -38,12 +38,15 @@ def updateTaskStorageDetails(task, sqrpc):
tasklist = task if isinstance(task, list) else [task] tasklist = task if isinstance(task, list) else [task]
if len(tasklist) == 0:
return
for t in tasklist: for t in tasklist:
applyDefaults(t) applyDefaults(t)
statuses = set(['finished', 'completing', 'aborted'])
tasklist = [t for t in tasklist if t['cluster'] == 'CEP4' and t['status'] in statuses]
if len(tasklist) == 0:
return
if not sqrpc: if not sqrpc:
return return
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment