diff --git a/interceptors-opentelemetry/package.json b/interceptors-opentelemetry/package.json index e7db7630..ec2c4888 100644 --- a/interceptors-opentelemetry/package.json +++ b/interceptors-opentelemetry/package.json @@ -20,10 +20,10 @@ ] }, "dependencies": { - "@opentelemetry/core": "^1.8.0", - "@opentelemetry/resources": "^1.8.0", - "@opentelemetry/sdk-node": "^0.33.0", - "@opentelemetry/sdk-trace-base": "^1.8.0", + "@opentelemetry/core": "^1.26.0", + "@opentelemetry/resources": "^1.26.0", + "@opentelemetry/sdk-node": "^0.53.0", + "@opentelemetry/sdk-trace-base": "^1.26.0", "@temporalio/activity": "^1.11.1", "@temporalio/client": "^1.11.1", "@temporalio/interceptors-opentelemetry": "^1.11.1", diff --git a/interceptors-opentelemetry/src/worker.ts b/interceptors-opentelemetry/src/worker.ts index 96791699..595abd9a 100644 --- a/interceptors-opentelemetry/src/worker.ts +++ b/interceptors-opentelemetry/src/worker.ts @@ -33,7 +33,7 @@ async function main() { interceptors: { // example contains both workflow and interceptors workflowModules: [require.resolve('./workflows')], - activityInbound: [(ctx) => new OpenTelemetryActivityInboundInterceptor(ctx)], + activity: [(ctx) => ({ inbound: new OpenTelemetryActivityInboundInterceptor(ctx) })], }, }); try { diff --git a/interceptors-opentelemetry/src/workflows.ts b/interceptors-opentelemetry/src/workflows.ts index 262b27e5..050e2b4d 100644 --- a/interceptors-opentelemetry/src/workflows.ts +++ b/interceptors-opentelemetry/src/workflows.ts @@ -2,6 +2,7 @@ import { proxyActivities, WorkflowInterceptorsFactory } from '@temporalio/workfl import { OpenTelemetryInboundInterceptor, OpenTelemetryOutboundInterceptor, + OpenTelemetryInternalsInterceptor, } from '@temporalio/interceptors-opentelemetry/lib/workflow'; import type * as activities from './activities'; @@ -18,4 +19,5 @@ export async function example(name: string): Promise { export const interceptors: WorkflowInterceptorsFactory = () => ({ inbound: [new OpenTelemetryInboundInterceptor()], outbound: [new OpenTelemetryOutboundInterceptor()], + internals: [new OpenTelemetryInternalsInterceptor()], });