fixed usage

Author: sanderegg

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

services/resource-usage-tracker/src/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,