From c16c6371357742df315eedfe75a25a2c500e19e7 Mon Sep 17 00:00:00 2001 From: Florian Date: Fri, 7 Nov 2025 18:24:26 +0100 Subject: [PATCH] Prevent premature garbage collection --- src/rabbitmq_handler.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/rabbitmq_handler.py b/src/rabbitmq_handler.py index 165192d..96a0bf9 100644 --- a/src/rabbitmq_handler.py +++ b/src/rabbitmq_handler.py @@ -65,9 +65,11 @@ class RabbitMQConsumer: await self.channel.declare_queue(self.dlq_queue_name, durable=True) metrics.start_metrics_server(port=9000) - asyncio.create_task(metrics.update_queue_gauge(self.channel, self.queue_name)) - asyncio.create_task(metrics.update_queue_gauge(self.channel, self.retry_queue_name)) - asyncio.create_task(metrics.update_queue_gauge(self.channel, self.dlq_queue_name)) + await asyncio.gather( + metrics.update_queue_gauge(self.channel, self.queue_name), + metrics.update_queue_gauge(self.channel, self.retry_queue_name), + metrics.update_queue_gauge(self.channel, self.dlq_queue_name), + ) logger.info("[RabbitMQ] Connected, exchange, retry, and DLQ queues ready.")