fix: if BROKER_URI is not defined, give the constructor None (#60)

ApeWorX · Mar 27, 2024 · d5c33a9 · d5c33a9
1 parent 48df76b
commit d5c33a9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/silverback/settings.py b/silverback/settings.py
@@ -46,7 +46,8 @@ def get_broker(self) -> AsyncBroker:
             broker = broker_class()
 
         else:
-            broker = broker_class(self.BROKER_URI)
+            # TODO: Not all brokers share a common arg signature.
+            broker = broker_class(self.BROKER_URI or None)
 
         middlewares: List[TaskiqMiddleware] = [SilverbackMiddleware(silverback_settings=self)]