[service] log line to track tasks that get delayed in execution

erdos-project · Dec 4, 2024 · ce582e0 · ce582e0
1 parent b4aceeb
commit ce582e0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/rpc/service.py b/rpc/service.py
@@ -753,6 +753,9 @@ async def NotifyTaskCompletion(self, request, context):
             self._logger.info(
                 f"[{stime}] Adding event {task_finished_event} to the simulator's event queue"
             )
+            if actual_task_completion_time < self.__stime():
+                self._logger.error(
+                    f"[{stime}] Task '{request.task_id}' of task graph '{r.task_graph.name}' had exceeded its runtime by {self.__stime() - actual_task_completion_time}")
 
             scheduler_start_event = Event(
                 event_type=EventType.SCHEDULER_START,