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

TMSS-671: minor fix

parent 11d597c5
No related branches found
No related tags found
1 merge request!715TMSS-671 & TMSS-1135 & TMSS-1332
...@@ -92,7 +92,7 @@ class TMSSSubTaskSchedulingEventMessageHandler(TMSSEventMessageHandler): ...@@ -92,7 +92,7 @@ class TMSSSubTaskSchedulingEventMessageHandler(TMSSEventMessageHandler):
if subtask.state.value == SubtaskState.Choices.DEFINED.value: if subtask.state.value == SubtaskState.Choices.DEFINED.value:
if subtask.specifications_template.type.value == SubtaskType.Choices.INGEST.value: if subtask.specifications_template.type.value == SubtaskType.Choices.INGEST.value:
if all(pred.state.value == SubtaskState.Choices.FINISHED.value or pred.is_obsolete for pred in subtask.predecessors.all()): if all(pred.state.value == SubtaskState.Choices.FINISHED.value or pred.is_obsolete for pred in subtask.predecessors.all()):
logger.info("trying to schedule ingest subtask id=%s for scheduling_unit_blueprint id=%s...", subtask['id'], id) logger.info("trying to schedule ingest subtask id=%s for scheduling_unit_blueprint id=%s...", subtask.id, id)
schedule_subtask(subtask, start_time=round_to_second_precision(datetime.utcnow()+timedelta(seconds=30))) schedule_subtask(subtask, start_time=round_to_second_precision(datetime.utcnow()+timedelta(seconds=30)))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment