Move target.apply down into startSpanManual

andreiborza · andreiborza · commit 93118f346847 · 2025-09-24T15:26:30.000+02:00
diff --git a/packages/core/src/utils/anthropic-ai/index.ts b/packages/core/src/utils/anthropic-ai/index.ts
@@ -210,8 +210,6 @@ function instrumentMethod<T extends unknown[], R>(
       const isStreamingMethod = methodPath === 'messages.stream';
 
       if (isStreamRequested || isStreamingMethod) {
-        const messageStream = target.apply(context, args);
-
         // Create span for instrumentation using startSpanManual
         return startSpanManual(
           {
@@ -225,6 +223,7 @@ function instrumentMethod<T extends unknown[], R>(
                 addPrivateRequestAttributes(span, params);
               }
 
+              const messageStream = target.apply(context, args);
               return instrumentStream(messageStream, span, options.recordOutputs ?? false);
             } catch (error) {
               span.setStatus({ code: SPAN_STATUS_ERROR, message: 'internal_error' });

Original file line number	Diff line number	Diff line change
`@@ -210,8 +210,6 @@ function instrumentMethod<T extends unknown[], R>(`
`210`	`210`	`const isStreamingMethod = methodPath === 'messages.stream';`
`211`	`211`
`212`	`212`	`if (isStreamRequested \|\| isStreamingMethod) {`
`213`		`- const messageStream = target.apply(context, args);`
`214`		`-`
`215`	`213`	`// Create span for instrumentation using startSpanManual`
`216`	`214`	`return startSpanManual(`
`217`	`215`	`{`
`@@ -225,6 +223,7 @@ function instrumentMethod<T extends unknown[], R>(`
`225`	`223`	`addPrivateRequestAttributes(span, params);`
`226`	`224`	`}`
`227`	`225`
	`226`	`+ const messageStream = target.apply(context, args);`
`228`	`227`	`return instrumentStream(messageStream, span, options.recordOutputs ?? false);`
`229`	`228`	`} catch (error) {`
`230`	`229`	`span.setStatus({ code: SPAN_STATUS_ERROR, message: 'internal_error' });`