Skip to content
Snippets Groups Projects
Commit ac2b5cd0 authored by Nico Vermaas's avatar Nico Vermaas
Browse files

omit discarded and suspended tasks

parent b9e28412
No related branches found
No related tags found
1 merge request!341SDC-1188 - final merge
Pipeline #72492 passed
...@@ -71,6 +71,7 @@ class TaskFilter(filters.FilterSet): ...@@ -71,6 +71,7 @@ class TaskFilter(filters.FilterSet):
# http://localhost:8000/atdb/tasks/?predecessor__isnull=True # http://localhost:8000/atdb/tasks/?predecessor__isnull=True
'predecessor': ['isnull'], 'predecessor': ['isnull'],
'predecessor__status': ['exact', 'icontains', 'in', 'startswith'], 'predecessor__status': ['exact', 'icontains', 'in', 'startswith'],
'activity' : ['isnull'],
'activity__id': ['exact'], 'activity__id': ['exact'],
'activity__ingested_fraction' : ['exact','lt', 'lte', 'gt', 'gte','isnull'], 'activity__ingested_fraction' : ['exact','lt', 'lte', 'gt', 'gte','isnull'],
} }
...@@ -1742,7 +1743,9 @@ def UpdateActivitySasId(request, sas_id): ...@@ -1742,7 +1743,9 @@ def UpdateActivitySasId(request, sas_id):
for task in tasks: for task in tasks:
i += 1 i += 1
if task.status not in ['discarded', 'suspended']:
activities_handler.update_activity(task) activities_handler.update_activity(task)
logger.info(f'{i} of {total} for sas_id = {sas_id}') logger.info(f'{i} of {total} for sas_id = {sas_id}')
logger.info(f'UpdateActivitySasId {sas_id}') logger.info(f'UpdateActivitySasId {sas_id}')
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment