fix: rmq url

subugoe · Sep 29, 2023 · ad08caf · ad08caf
1 parent eb2a987
commit ad08caf
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/server/operandi_server/routers/workflow.py b/src/server/operandi_server/routers/workflow.py
@@ -44,9 +44,10 @@
 
 # TODO: Fix this, the correct import must be made according to the env
 try:
-    from tests.constants import OPERANDI_RABBITMQ_URL
+    from tests.constants import OPERANDI_RABBITMQ_URL as RMQ_URL
+    OPERANDI_RABBITMQ_URL = RMQ_URL
 except Exception as e:
-    OPERANDI_RABBITMQ_URL = "http://localhost:5672"
+    OPERANDI_RABBITMQ_URL = "amqp://operandi_user:operandi_password@localhost:5672/"
 
 router = APIRouter(tags=["Workflow"])
 logger = logging.getLogger(__name__)