We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a0aff6f commit 4f805ffCopy full SHA for 4f805ff
src/common/dramatiq.py
@@ -13,7 +13,7 @@ def init_dramatiq(config: AppConfig):
13
broker = StubBroker()
14
# broker.emit_after("process_boot")
15
elif config.DRAMATIQ.REDIS_URL is not None:
16
- broker = RedisBroker(host=config.DRAMATIQ.REDIS_URL)
+ broker = RedisBroker(url=config.DRAMATIQ.REDIS_URL)
17
else:
18
raise RuntimeError("Running a non-test environment without Redis URL set")
19
broker.add_middleware(AsyncIO())
0 commit comments