fix(server): fixing context propagation on nats (#3676)

kubeshop · Feb 23, 2024 · 3db3b9f · 3db3b9f
1 parent e9e3601
commit 3db3b9f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/server/pkg/pipeline/queue.go b/server/pkg/pipeline/queue.go
@@ -82,7 +82,9 @@ func (q Queue[T]) Enqueue(ctx context.Context, item T) {
 
 	workerCtx := context.Background()
 	if propagator := otel.GetTextMapPropagator(); propagator != nil {
-		var carrier propagation.HeaderCarrier
+		carrier := make(propagation.HeaderCarrier)
+		propagator.Inject(ctx, carrier)
+
 		workerCtx = propagator.Extract(workerCtx, carrier)
 	}