fixed issue

Author: sanderegg

services/director-v2/src/simcore_service_director_v2/modules/dask_client.py

@@ -487,6 +487,17 @@ async def _get_task_state(job_id: str) -> RunningState:
                         ),
                     )
                     return RunningState.UNKNOWN
+                except KeyError as exc:
+                    # the task does not exist
+                    _logger.warning(
+                        **create_troubleshootting_log_kwargs(
+                            f"Task {job_id} not found. State is UNKNOWN.",
+                            error=exc,
+                            error_context=log_error_context,
+                            tip="If the task is supposed to exist, the dask-schdeler has probably restarted. Check its status.",
+                        ),
+                    )
+                    return RunningState.UNKNOWN
 
             return parsed_event.state