From ce582e072231c190a2bcaf4492cb13c756d2c92d Mon Sep 17 00:00:00 2001 From: Dhruv Garg Date: Wed, 4 Dec 2024 01:26:01 -0500 Subject: [PATCH] [service] log line to track tasks that get delayed in execution --- rpc/service.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/rpc/service.py b/rpc/service.py index 11040e41..55537d8c 100644 --- 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,