Skip to content

Commit 9fec342

Browse files
juznabrettlangdon
andauthored
fix(tracing): activate distributed headers in the rq integration (#13571)
This was forgotten in 9a5fd14. ## Checklist - [x] PR author has checked that all the criteria below are met - The PR description includes an overview of the change - The PR description articulates the motivation for the change - The change includes tests OR the PR description describes a testing strategy - The PR description notes risks associated with the change, if any - Newly-added code is easy to change - The change follows the [library release note guidelines](https://ddtrace.readthedocs.io/en/stable/releasenotes.html) - The change includes or references documentation updates if necessary - Backport labels are set (if [applicable](https://ddtrace.readthedocs.io/en/latest/contributing.html#backporting)) ## Reviewer Checklist - [x] Reviewer has checked that all the criteria below are met - Title is accurate - All changes are related to the pull request's stated goal - Avoids breaking [API](https://ddtrace.readthedocs.io/en/stable/versioning.html#interfaces) changes - Testing strategy adequately addresses listed risks - Newly-added code is easy to change - Release note makes sense to a user of the library - If necessary, author has acknowledged and discussed the performance implications of this PR as reported in the benchmarks PR comment - Backport labels are set in a manner that is consistent with the [release branch maintenance policy](https://ddtrace.readthedocs.io/en/latest/contributing.html#backporting) --------- Co-authored-by: brettlangdon <[email protected]>
1 parent c335af9 commit 9fec342

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

ddtrace/contrib/internal/rq/patch.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -118,6 +118,7 @@ def traced_perform_job(rq, pin, func, instance, args, kwargs):
118118
resource=job.func_name,
119119
integration_config=config.rq_worker,
120120
distributed_headers=job.meta,
121+
activate_distributed_headers=True,
121122
tags={COMPONENT: config.rq.integration_name, SPAN_KIND: SpanKind.CONSUMER, JOB_ID: job.get_id()},
122123
) as ctx, ctx.span:
123124
try:
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
---
2+
fixes:
3+
- |
4+
rq: enable parsing distributed tracing metadata in perform job

0 commit comments

Comments
 (0)