File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
services/dask-sidecar/src/simcore_service_dask_sidecar Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -64,16 +64,18 @@ async def dask_setup(worker: distributed.Worker) -> None:
6464 with log_context (_logger , logging .INFO , "Launch dask worker" ):
6565 _logger .info ("app settings: %s" , settings .model_dump_json (indent = 1 ))
6666
67- print_dask_sidecar_banner ()
68-
6967 if threading .current_thread () is threading .main_thread ():
7068 GracefulKiller (worker )
7169
7270 loop = asyncio .get_event_loop ()
7371 _logger .info ("We do have a running loop in the main thread: %s" , f"{ loop = } " )
7472
7573 if settings .DASK_SIDECAR_RABBITMQ :
76- await worker .plugin_add (RabbitMQPlugin (settings .DASK_SIDECAR_RABBITMQ ))
74+ await worker .plugin_add (
75+ RabbitMQPlugin (settings .DASK_SIDECAR_RABBITMQ ), catch_errors = False
76+ )
77+
78+ print_dask_sidecar_banner ()
7779
7880
7981async def dask_teardown (worker : distributed .Worker ) -> None :
You can’t perform that action at this time.
0 commit comments