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 1351101 commit 6b66460Copy full SHA for 6b66460
src/common/dramatiq.py
@@ -28,7 +28,9 @@ def decode(self, data: bytes) -> MessageData:
28
def init_dramatiq(config: AppConfig):
29
broker: Broker
30
31
- DramatiqInstrumentor().instrument()
+ dramatiq_instrumentor = DramatiqInstrumentor()
32
+ if not dramatiq_instrumentor.is_instrumented_by_opentelemetry:
33
+ dramatiq_instrumentor.instrument()
34
35
if config.DRAMATIQ.REDIS_URL is not None:
36
broker = RedisBroker(url=config.DRAMATIQ.REDIS_URL)
0 commit comments