Skip to content

Commit

Permalink
Update OTEL dependencies (#383)
Browse files Browse the repository at this point in the history
  • Loading branch information
mjameswh authored Sep 12, 2024
1 parent 6ecf7ce commit e126c56
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 5 deletions.
8 changes: 4 additions & 4 deletions interceptors-opentelemetry/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -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",
Expand Down
2 changes: 1 addition & 1 deletion interceptors-opentelemetry/src/worker.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down
2 changes: 2 additions & 0 deletions interceptors-opentelemetry/src/workflows.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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';

Expand All @@ -18,4 +19,5 @@ export async function example(name: string): Promise<string> {
export const interceptors: WorkflowInterceptorsFactory = () => ({
inbound: [new OpenTelemetryInboundInterceptor()],
outbound: [new OpenTelemetryOutboundInterceptor()],
internals: [new OpenTelemetryInternalsInterceptor()],
});

0 comments on commit e126c56

Please sign in to comment.