From 8c98cd688b4c556694ba2dd893b95895694e7d69 Mon Sep 17 00:00:00 2001 From: Sukrit Kalra Date: Mon, 8 Jan 2024 19:27:12 -0800 Subject: [PATCH] Better logging to diagnose non-completed and non-cancelled TaskGraphs. --- workload/workload.py | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/workload/workload.py b/workload/workload.py index f2665083..e979ead8 100644 --- a/workload/workload.py +++ b/workload/workload.py @@ -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