fix: amqp broker url

ICIJ · Nov 21, 2024 · 4abc6db · 4abc6db
1 parent 92e9b1e
commit 4abc6db
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/icij-worker/icij_worker/utils/amqp.py b/icij-worker/icij_worker/utils/amqp.py
@@ -100,7 +100,8 @@ class AMQPConfigMixin(ICIJModel):
     @cached_property
     def broker_url(self) -> str:
         amqp_userinfo = self.rabbitmq_user
-        amqp_userinfo += f":{self.rabbitmq_password}"
+        if self.rabbitmq_password:
+            amqp_userinfo += f":{self.rabbitmq_password}"
         if amqp_userinfo:
             amqp_userinfo += "@"
         amqp_authority = (