We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0cf6c53 commit 943dec0Copy full SHA for 943dec0
1 file changed
sentry_sdk/integrations/rq.py
@@ -156,10 +156,12 @@ def sentry_patched_enqueue_job(
156
return old_enqueue_job(self, job, **kwargs)
157
158
scope = sentry_sdk.get_current_scope()
159
- span_streaming = has_span_streaming_enabled(client.options)
160
- if (span_streaming and scope.streamed_span is not None) or (
161
- not span_streaming and scope.span is not None
162
- ):
+ span = (
+ scope.streamed_span
+ if has_span_streaming_enabled(client.options)
+ else scope.span
163
+ )
164
+ if span is not None:
165
job.meta["_sentry_trace_headers"] = dict(
166
scope.iter_trace_propagation_headers()
167
)
0 commit comments