From 295c1f68e08cd24691f41ac352146da53fffe759 Mon Sep 17 00:00:00 2001 From: UdoChudo Date: Mon, 23 Jun 2025 00:38:25 +0500 Subject: [PATCH] chore: (rabbitmq flask client) optimize imports to resolve warnings Signed-off-by: UdoChudo --- app/extensions/rabbitmq.py | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/app/extensions/rabbitmq.py b/app/extensions/rabbitmq.py index 23ebbb5..52b3de3 100644 --- a/app/extensions/rabbitmq.py +++ b/app/extensions/rabbitmq.py @@ -1,7 +1,11 @@ -import pika -from config import RABBITMQ_HOST, RABBITMQ_PORT, RABBITMQ_LOGIN, RABBITMQ_PASS, RABBITMQ_QUEUE import time +import pika +from pika.exceptions import ChannelClosedByBroker, ConnectionClosed, AMQPConnectionError + +from config import RABBITMQ_HOST, RABBITMQ_PORT, RABBITMQ_LOGIN, RABBITMQ_PASS, RABBITMQ_QUEUE + + class RabbitMQClient: def __init__(self): self._connect() @@ -31,9 +35,9 @@ class RabbitMQClient: delivery_mode=2, ) ) - except (pika.exceptions.ChannelClosedByBroker, - pika.exceptions.ConnectionClosed, - pika.exceptions.AMQPConnectionError) as e: + except (ChannelClosedByBroker, + ConnectionClosed, + AMQPConnectionError) as e: if retry > 0: # Короткая пауза перед переподключением time.sleep(1)