renamed

Author: sanderegg

services/dask-sidecar/src/simcore_service_dask_sidecar/rabbitmq_plugin.py renamed to services/dask-sidecar/src/simcore_service_dask_sidecar/rabbitmq_worker_plugin.py

@@ -24,7 +24,7 @@
 class RabbitMQPlugin(distributed.WorkerPlugin):
     """Dask Worker Plugin for RabbitMQ integration"""
 
-    name = "rabbitmq_plugin"
+    name = "rabbitmq_worker_plugin"
     _main_thread_loop: AbstractEventLoop | None = None
     _client: RabbitMQClient | None = None
     _settings: RabbitSettings | None = None

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

@@ -19,7 +19,7 @@
 from models_library.rabbitmq_messages import LoggerRabbitMessage
 from servicelib.logging_utils import LogLevelInt, LogMessageStr, log_catch, log_context
 
-from ..rabbitmq_plugin import get_rabbitmq_client
+from ..rabbitmq_worker_plugin import get_rabbitmq_client
 
 _logger = logging.getLogger(__name__)
 

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

@@ -16,7 +16,7 @@
 
 from ._meta import print_dask_sidecar_banner
 from .computational_sidecar.core import ComputationalSidecar
-from .rabbitmq_plugin import RabbitMQPlugin
+from .rabbitmq_worker_plugin import RabbitMQPlugin
 from .settings import ApplicationSettings
 from .task_life_cycle_worker_plugin import (
     TaskLifecycleWorkerPlugin,

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

@@ -24,7 +24,7 @@ def test_rabbitmq_plugin_initializes(dask_client: distributed.Client): ...
 @pytest.fixture
 def erroring_rabbitmq_plugin(mocker: MockerFixture) -> mock.Mock:
     return mocker.patch(
-        "simcore_service_dask_sidecar.rabbitmq_plugin.RabbitMQPlugin",
+        "simcore_service_dask_sidecar.rabbitmq_worker_plugin.RabbitMQPlugin",
         autospec=True,
         side_effect=RuntimeError("Pytest: RabbitMQ plugin initialization failed"),
     )

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

@@ -113,7 +113,8 @@ def dask_subsystem_mock(
     )
     # mock dask rabbitmq plugin
     mock_dask_rabbitmq_plugin = mocker.patch(
-        "simcore_service_dask_sidecar.rabbitmq_plugin.RabbitMQPlugin", autospec=True
+        "simcore_service_dask_sidecar.rabbitmq_worker_plugin.RabbitMQPlugin",
+        autospec=True,
     )
     mock_rabbitmq_client = create_rabbitmq_client("pytest_dask_sidecar_logs_publisher")
     mock_dask_rabbitmq_plugin.get_client.return_value = mock_rabbitmq_client