diff --git a/service/utils/rabbitmq.py b/service/utils/rabbitmq.py
index 117de91..c8a89c5 100644
--- a/service/utils/rabbitmq.py
+++ b/service/utils/rabbitmq.py
@@ -1,13 +1,13 @@
 import pika
-from pika.credentials import PlainCredentials
 import json
 import time
 import logging
 
 from settings import settings
 
+creds = pika.PlainCredentials(settings.RABBITMQ_USERNAME, settings.RABBITMQ_PASSWORD)
 conn_config = pika.ConnectionParameters(
-    host=settings.RABBITMQ_HOST, port=settings.RABBITMQ_PORT
+    host=settings.RABBITMQ_HOST, port=settings.RABBITMQ_PORT, credentials=creds
 )
 
 
@@ -36,9 +36,6 @@ def callback(ch, method, properties, body):
 def gen_rabbitmq_hook(job_id):
     connection = pika.BlockingConnection(
         conn_config,
-        credentials=PlainCredentials(
-            username=settings.RABBITMQ_USERNAME, password=settings.RABBITMQ_PASSWORD
-        ),
     )
     channel = connection.channel()