ongoing

Author: sanderegg

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

@@ -361,6 +361,13 @@ async def _process_task_result(
                 else:
                     if isinstance(result, TaskCancelledError):
                         task_final_state = RunningState.ABORTED
+                    # elif isinstance(
+                    #     result, ComputationalBackendTaskResultsNotReadyError
+                    # ):
+                    #     # we did not manage to get the current state of the task
+                    #     # so we keep it as is
+                    #     task_final_state = task.state
+                    # elif isinstance(result, ComputationalBackendNotConnectedError):
                     else:
                         task_final_state = RunningState.FAILED
                         errors.append(