Skip to content

Commit

Permalink
Better logging to diagnose non-completed and non-cancelled TaskGraphs.
Browse files Browse the repository at this point in the history
  • Loading branch information
sukritkalra committed Jan 9, 2024
1 parent ead2ed4 commit 8c98cd6
Showing 1 changed file with 11 additions and 1 deletion.
12 changes: 11 additions & 1 deletion workload/workload.py
Original file line number Diff line number Diff line change
Expand Up @@ -348,9 +348,19 @@ def get_cancelled_task_graphs(self) -> Sequence[TaskGraph]:
task_graph.deadline,
task_graph.completion_time,
)
elif task_graph.is_complete():
self._logger.debug(
"The TaskGraph %s completed at %s, and met its deadline of %s.",
task_graph.name,
task_graph.completion_time,
task_graph.deadline,
)
else:
self._logger.debug(
"The TaskGraph %s was not cancelled.", task_graph.name
"The TaskGraph %s was not cancelled. "
"Its sinks are in the state %s.",
task_graph.name,
[task.state for task in task_graph.get_sink_tasks()],
)
return cancelled_task_graphs

Expand Down

0 comments on commit 8c98cd6

Please sign in to comment.