Skip to content

Commit c962e50

Browse files
committed
ensure errors do not let the sidecar start
1 parent f147bb8 commit c962e50

File tree

1 file changed

+5
-3
lines changed
  • services/dask-sidecar/src/simcore_service_dask_sidecar

1 file changed

+5
-3
lines changed

services/dask-sidecar/src/simcore_service_dask_sidecar/worker.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff 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

7981
async def dask_teardown(worker: distributed.Worker) -> None:

0 commit comments

Comments
 (0)