@@ -20,7 +20,7 @@ def dask_workers_config() -> dict[str, Any]:
2020 "nthreads" : 2 ,
2121 "resources" : {"CPU" : 2 , "RAM" : 48e9 },
2222 "preload" : (
23- "simcore_service_dask_sidecar .task_life_cycle_worker_plugin" ,
23+ "dask_task_models_library.plugins .task_life_cycle_worker_plugin" ,
2424 ),
2525 },
2626 },
@@ -34,7 +34,7 @@ def dask_workers_config() -> dict[str, Any]:
3434 "RAM" : 48e9 ,
3535 },
3636 "preload" : (
37- "simcore_service_dask_sidecar .task_life_cycle_worker_plugin" ,
37+ "dask_task_models_library.plugins .task_life_cycle_worker_plugin" ,
3838 ),
3939 },
4040 },
@@ -47,7 +47,7 @@ def dask_workers_config() -> dict[str, Any]:
4747 "RAM" : 768e9 ,
4848 },
4949 "preload" : (
50- "simcore_service_dask_sidecar .task_life_cycle_worker_plugin" ,
50+ "dask_task_models_library.plugins .task_life_cycle_worker_plugin" ,
5151 ),
5252 },
5353 },
@@ -64,7 +64,7 @@ def dask_scheduler_config(
6464 "port" : unused_tcp_port_factory (),
6565 "dashboard_address" : f":{ unused_tcp_port_factory ()} " ,
6666 "preload" : (
67- "simcore_service_dask_sidecar .task_life_cycle_scheduler_plugin" ,
67+ "dask_task_models_library.plugins .task_life_cycle_scheduler_plugin" ,
6868 ),
6969 },
7070 }
0 commit comments