We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7ba19d2 commit 00e4ef7Copy full SHA for 00e4ef7
cogstack_model_gateway/common/queue.py
@@ -25,6 +25,8 @@ def __init__(
25
connection_url: str = None,
26
max_concurrent_tasks: int = 1,
27
):
28
+ logging.getLogger("pika").setLevel(logging.WARNING)
29
+
30
if user and password and host and port:
31
self.connection_url = f"amqp://{user}:{password}@{host}:{port}/"
32
elif connection_url:
0 commit comments