rename files

Author: sanderegg

services/dask-sidecar/docker/boot.sh

@@ -173,7 +173,7 @@ else
     exec watchmedo auto-restart --recursive --pattern="*.py;*/src/*" --ignore-patterns="*test*;pytest_simcore/*;setup.py;*ignore*" --ignore-directories -- \
       dask worker "${DASK_SCHEDULER_URL}" \
       --local-directory /tmp/dask-sidecar \
-      --preload simcore_service_dask_sidecar.tasks \
+      --preload simcore_service_dask_sidecar.worker \
       --nworkers ${DASK_NPROCS} \
       --nthreads "${DASK_NTHREADS}" \
       --dashboard-address 8787 \
@@ -183,7 +183,7 @@ else
   else
     exec dask worker "${DASK_SCHEDULER_URL}" \
       --local-directory /tmp/dask-sidecar \
-      --preload simcore_service_dask_sidecar.tasks \
+      --preload simcore_service_dask_sidecar.worker \
       --nworkers ${DASK_NPROCS} \
       --nthreads "${DASK_NTHREADS}" \
       --dashboard-address 8787 \

services/dask-sidecar/src/simcore_service_dask_sidecar/tasks.py renamed to services/dask-sidecar/src/simcore_service_dask_sidecar/worker.py

@@ -108,7 +108,7 @@ def local_cluster(app_environment: EnvVarsDict) -> Iterator[distributed.LocalClu
     with distributed.LocalCluster(
         worker_class=distributed.Worker,
         resources={"CPU": 10, "GPU": 10},
-        preload="simcore_service_dask_sidecar.tasks",
+        preload="simcore_service_dask_sidecar.worker",
     ) as cluster:
         assert cluster
         assert isinstance(cluster, distributed.LocalCluster)
@@ -131,7 +131,7 @@ async def async_local_cluster(
     async with distributed.LocalCluster(
         worker_class=distributed.Worker,
         resources={"CPU": 10, "GPU": 10},
-        preload="simcore_service_dask_sidecar.tasks",
+        preload="simcore_service_dask_sidecar.worker",
         asynchronous=True,
     ) as cluster:
         assert cluster

services/dask-sidecar/tests/unit/conftest.py

@@ -58,7 +58,7 @@
 )
 from simcore_service_dask_sidecar.dask_utils import _DEFAULT_MAX_RESOURCES
 from simcore_service_dask_sidecar.file_utils import _s3fs_settings_from_s3_settings
-from simcore_service_dask_sidecar.tasks import run_computational_sidecar
+from simcore_service_dask_sidecar.worker import run_computational_sidecar
 
 logger = logging.getLogger(__name__)
 

services/dask-sidecar/tests/unit/test_tasks.py

@@ -223,7 +223,7 @@ def _comp_sidecar_fct(
         ) -> TaskOutputData:
             """This function is serialized by the Dask client and sent over to the Dask sidecar(s)
             Therefore, (screaming here) DO NOT MOVE THAT IMPORT ANYWHERE ELSE EVER!!"""
-            from simcore_service_dask_sidecar.tasks import (  # type: ignore[import-not-found]  # this runs inside the dask-sidecar
+            from simcore_service_dask_sidecar.worker import (  # type: ignore[import-not-found]  # this runs inside the dask-sidecar
                 run_computational_sidecar,
             )