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 {