fixed usage

sanderegg · Nov 26, 2024 · d7e70fb · d7e70fb
1 parent 0fd6e64
commit d7e70fb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/services/efs-guardian/src/simcore_service_efs_guardian/services/process_messages_setup.py b/services/efs-guardian/src/simcore_service_efs_guardian/services/process_messages_setup.py
@@ -25,7 +25,7 @@
 async def _subscribe_to_rabbitmq(app) -> str:
     with log_context(_logger, logging.INFO, msg="Subscribing to rabbitmq channel"):
         rabbit_client: RabbitMQClient = get_rabbitmq_client(app)
-        subscribed_queue: str = await rabbit_client.subscribe(
+        subscribed_queue, _ = await rabbit_client.subscribe(
             DynamicServiceRunningMessage.get_channel_name(),
             message_handler=functools.partial(
                 process_dynamic_service_running_message, app

diff --git a/.../simcore_service_resource_usage_tracker/services/process_message_running_service_setup.py b/.../simcore_service_resource_usage_tracker/services/process_message_running_service_setup.py
@@ -20,7 +20,7 @@
 async def _subscribe_to_rabbitmq(app) -> str:
     with log_context(_logger, logging.INFO, msg="Subscribing to rabbitmq channel"):
         rabbit_client: RabbitMQClient = get_rabbitmq_client(app)
-        subscribed_queue: str = await rabbit_client.subscribe(
+        subscribed_queue, _ = await rabbit_client.subscribe(
             RabbitResourceTrackingBaseMessage.get_channel_name(),
             message_handler=functools.partial(process_message, app),
             exclusive_queue=False,