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 5d15199 commit 0e496edCopy full SHA for 0e496ed
src/workflows/services/common_service.py
@@ -203,6 +203,10 @@ def start_transport(self):
203
else:
204
self.log.debug("No transport layer defined for service. Skipping.")
205
206
+ from workflows.transport.middleware.tracer import TracerMiddleware
207
+ instrument = TracerMiddleware(self.__class__.__name__)
208
+ self._transport.add_middleware(instrument)
209
+
210
def stop_transport(self):
211
"""If a transport object has been defined then tear it down."""
212
if self.transport:
0 commit comments