remove await in incoming activity

chris-olszewski · chris-olszewski · commit 8cfa9a1c93b6 · 2025-10-31T14:05:58.000-04:00
diff --git a/packages/interceptors-opentelemetry/src/worker/index.ts b/packages/interceptors-opentelemetry/src/worker/index.ts
@@ -34,7 +34,7 @@ export class OpenTelemetryActivityInboundInterceptor implements ActivityInboundC
   }
 
   async execute(input: ActivityExecuteInput, next: Next<ActivityInboundCallsInterceptor, 'execute'>): Promise<unknown> {
-    const context = await Promise.resolve(extractContextFromHeaders(input.headers));
+    const context = extractContextFromHeaders(input.headers);
     const spanName = `${SpanName.ACTIVITY_EXECUTE}${SPAN_DELIMITER}${this.ctx.info.activityType}`;
     return await instrument({ tracer: this.tracer, spanName, fn: () => next(input), context });
   }

Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ export class OpenTelemetryActivityInboundInterceptor implements ActivityInboundC`
`34`	`34`	`}`
`35`	`35`
`36`	`36`	`async execute(input: ActivityExecuteInput, next: Next<ActivityInboundCallsInterceptor, 'execute'>): Promise<unknown> {`
`37`		`- const context = await Promise.resolve(extractContextFromHeaders(input.headers));`
	`37`	`+ const context = extractContextFromHeaders(input.headers);`
`38`	`38`	const spanName = `${SpanName.ACTIVITY_EXECUTE}${SPAN_DELIMITER}${this.ctx.info.activityType}`;
`39`	`39`	`return await instrument({ tracer: this.tracer, spanName, fn: () => next(input), context });`
`40`	`40`	`}`