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 index deb151fbda5d..2afd34d2f429 100644 --- 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/services/resource-usage-tracker/src/simcore_service_resource_usage_tracker/services/process_message_running_service_setup.py b/services/resource-usage-tracker/src/simcore_service_resource_usage_tracker/services/process_message_running_service_setup.py index 3624eb1254d9..c393626e469e 100644 --- a/services/resource-usage-tracker/src/simcore_service_resource_usage_tracker/services/process_message_running_service_setup.py +++ b/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,