From e3eff12ccdea52e041cc7a14cda72d3e32aa2144 Mon Sep 17 00:00:00 2001 From: Julius Unverfehrt Date: Tue, 22 Mar 2022 15:42:35 +0100 Subject: [PATCH] black --- pyinfra/queue/queue_manager/pika_queue_manager.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/pyinfra/queue/queue_manager/pika_queue_manager.py b/pyinfra/queue/queue_manager/pika_queue_manager.py index 1228346..3b91fea 100644 --- a/pyinfra/queue/queue_manager/pika_queue_manager.py +++ b/pyinfra/queue/queue_manager/pika_queue_manager.py @@ -45,7 +45,12 @@ def get_connection(): credentials = pika.PlainCredentials(username=CONFIG.rabbitmq.user, password=CONFIG.rabbitmq.password) - kwargs = {"host": CONFIG.rabbitmq.host, "port": CONFIG.rabbitmq.port, "credentials": credentials, "heartbeat": CONFIG.rabbitmq.heartbeat} + kwargs = { + "host": CONFIG.rabbitmq.host, + "port": CONFIG.rabbitmq.port, + "credentials": credentials, + "heartbeat": CONFIG.rabbitmq.heartbeat, + } parameters = pika.ConnectionParameters(**kwargs)