moving credentials

DARPA-ASKEM · Aug 15, 2023 · 26ff02a · 26ff02a
1 parent 5872526
commit 26ff02a
Showing 1 changed file with 2 additions and 5 deletions.
diff --git 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()