Skip to content

Commit

Permalink
ensure losing connection to a dask-scheduler doesn't crash the whole …
Browse files Browse the repository at this point in the history
…scheduler
  • Loading branch information
sanderegg committed Dec 20, 2023
1 parent 55651e4 commit ba8d106
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -670,6 +670,8 @@ async def _schedule_pipeline(
user_id, project_id, iteration, RunningState.ABORTED
)
self.scheduled_pipelines.pop((user_id, project_id, iteration), None)
except ComputationalBackendNotConnectedError:
_logger.exception("Computational backend is not connected!")

async def _schedule_tasks_to_stop(
self,
Expand Down

0 comments on commit ba8d106

Please sign in to comment.