clean

Author: sanderegg

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

@@ -19,7 +19,6 @@
 from .computational_sidecar.core import ComputationalSidecar
 from .dask_utils import TaskPublisher, get_current_task_resources, monitor_task_abortion
 from .rabbitmq import RabbitMQPlugin
-from .rabbitmq import on_shutdown as shutdown_rabbitmq
 from .settings import ApplicationSettings
 
 _logger = logging.getLogger(__name__)
@@ -86,9 +85,9 @@ async def dask_setup(worker: distributed.Worker) -> None:
                 await worker.plugin_add(RabbitMQPlugin(settings.DASK_SIDECAR_RABBITMQ))
 
 
-async def dask_teardown(worker: distributed.Worker) -> None:
+async def dask_teardown(_worker: distributed.Worker) -> None:
     with log_context(dask_worker_logger, logging.INFO, "tear down dask worker"):
-        await shutdown_rabbitmq(worker)
+        ...
 
 
 async def _run_computational_sidecar_async(

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

@@ -4,6 +4,7 @@
 
 import re
 from pathlib import Path
+from typing import TypeAlias
 
 import pytest
 
@@ -16,11 +17,13 @@ def requirements_folder(project_slug_dir: Path) -> Path:
     return reqs_dir
 
 
+NameVersionTuple: TypeAlias = tuple[str, str]
+
+
 def test_dask_requirements_in_sync(requirements_folder: Path):
     """If this test fails, do update requirements to re-sync all listings"""
 
     REQS_ENTRY_REGEX = re.compile(r"(\w+)==([\.\w]+)")
-    NameVersionTuple = tuple[str, str]
 
     def get_reqs(fname: str) -> set[NameVersionTuple]:
         return set(REQS_ENTRY_REGEX.findall((requirements_folder / fname).read_text()))