From ecf650eb44e3ec18df3f358e0664a96dac889501 Mon Sep 17 00:00:00 2001
From: steffen911 <steffen@langfuse.com>
Date: Tue, 15 Oct 2024 10:26:16 -0700
Subject: [PATCH] fix: use correct parentContext for consumerContext

---
 src/instrumentation.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/instrumentation.ts b/src/instrumentation.ts
index 6c81170..798e083 100644
--- a/src/instrumentation.ts
+++ b/src/instrumentation.ts
@@ -508,7 +508,7 @@ export class BullMQInstrumentation extends InstrumentationBase {
           parentContext,
         );
 
-        const consumerContext = trace.setSpan(currentContext, span);
+        const consumerContext = trace.setSpan(parentContext, span);
 
         return await context.with(consumerContext, async () => {
           try {