Update services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_scheduler_dask.py

sanderegg · Copilot · sanderegg · commit 6ae5537719f3 · 2025-09-09T07:49:00.000+02:00
Co-authored-by: Copilot &lt;175728472+Copilot@users.noreply.github.com&gt;
diff --git a/services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_scheduler_dask.py b/services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_scheduler_dask.py
@@ -353,7 +353,7 @@ async def _process_task_result(
                     )
                     task_final_state = RunningState.SUCCESS
                 elif isinstance(result, ComputationalBackendTaskResultsNotReadyError):
-                    # we did not manage to get the current state of the task
+                    # Task result retrieval failed due to communication error, task will be retried
                     # so we keep it as is
                     assert task.job_id  # nosec
                     return False, task.job_id

Original file line number	Diff line number	Diff line change
`@@ -353,7 +353,7 @@ async def _process_task_result(`
`353`	`353`	`)`
`354`	`354`	`task_final_state = RunningState.SUCCESS`
`355`	`355`	`elif isinstance(result, ComputationalBackendTaskResultsNotReadyError):`
`356`		`- # we did not manage to get the current state of the task`
	`356`	`+ # Task result retrieval failed due to communication error, task will be retried`
`357`	`357`	`# so we keep it as is`
`358`	`358`	`assert task.job_id # nosec`
`359`	`359`	`return False, task.job_id`