chore: Upgrade opentelemetry dependencies (#1107)

Co-authored-by: Max Gurewitz <maxgurewitz@gmail.com>

Author: bergundy

package-lock.json

@@ -50,10 +50,10 @@
     "temporalio": "file:packages/meta"
   },
   "devDependencies": {
-    "@opentelemetry/api": "^1.3.0",
-    "@opentelemetry/core": "^1.8.0",
-    "@opentelemetry/sdk-node": "^0.34.0",
-    "@opentelemetry/semantic-conventions": "^1.8.0",
+    "@opentelemetry/api": "^1.4.1",
+    "@opentelemetry/core": "^1.12.0",
+    "@opentelemetry/sdk-node": "^0.38.0",
+    "@opentelemetry/semantic-conventions": "^1.12.0",
     "@tsconfig/node14": "^1.0.3",
     "@types/dedent": "^0.7.0",
     "@types/fs-extra": "^9.0.13",

package.json

@@ -4,6 +4,7 @@ import {
   searchAttributePayloadConverter,
   SearchAttributes,
 } from '@temporalio/common';
+import { Replace } from '@temporalio/common/lib/type-helpers';
 import { optionalTsToDate, tsToDate } from '@temporalio/common/lib/time';
 import { decodeMapFromPayloads } from '@temporalio/common/lib/internal-non-workflow/codec-helpers';
 import { temporal } from '@temporalio/proto';
@@ -39,10 +40,11 @@ function workflowStatusCodeToNameInternal(
   }
 }
 
-export async function executionInfoFromRaw(
+export async function executionInfoFromRaw<T>(
   raw: RawWorkflowExecutionInfo,
-  dataConverter: LoadedDataConverter
-): Promise<WorkflowExecutionInfo> {
+  dataConverter: LoadedDataConverter,
+  rawDataToEmbed: T
+): Promise<Replace<WorkflowExecutionInfo, { raw: T }>> {
   return {
     /* eslint-disable @typescript-eslint/no-non-null-assertion */
     type: raw.type!.name!,
@@ -70,6 +72,6 @@ export async function executionInfoFromRaw(
           runId: raw.parentExecution.runId!,
         }
       : undefined,
-    raw,
+    raw: rawDataToEmbed,
   };
 }

packages/client/src/helpers.ts

@@ -764,13 +764,13 @@ export const MONTHS = [
 ] as const;
 
 /** @experimental */
-export type Month = typeof MONTHS[number];
+export type Month = (typeof MONTHS)[number];
 
 /** @experimental */
 export const DAYS_OF_WEEK = ['SUNDAY', 'MONDAY', 'TUESDAY', 'WEDNESDAY', 'THURSDAY', 'FRIDAY', 'SATURDAY'] as const;
 
 /** @experimental */
-export type DayOfWeek = typeof DAYS_OF_WEEK[number];
+export type DayOfWeek = (typeof DAYS_OF_WEEK)[number];
 
 /** @experimental */
 export type ScheduleOptionsAction = ScheduleOptionsStartWorkflowAction<Workflow>;

packages/client/src/schedule-types.ts

@@ -841,9 +841,11 @@ export class WorkflowClient extends BaseClient {
         const raw = await fn({
           workflowExecution: { workflowId, runId },
         });
-        const info = await executionInfoFromRaw(raw.workflowExecutionInfo ?? {}, this.client.dataConverter);
-        (info as unknown as WorkflowExecutionDescription).raw = raw;
-        return info;
+        const info = await executionInfoFromRaw(raw.workflowExecutionInfo ?? {}, this.client.dataConverter, raw);
+        return {
+          ...info,
+          raw,
+        };
       },
       async fetchHistory() {
         let nextPageToken: Uint8Array | undefined = undefined;
@@ -933,7 +935,7 @@ export class WorkflowClient extends BaseClient {
       // Decoding is done for `memo` fields which tend to be small.
       // We might decide to change that based on user feedback.
       for (const raw of response.executions) {
-        yield await executionInfoFromRaw(raw, this.dataConverter);
+        yield await executionInfoFromRaw(raw, this.dataConverter, raw);
       }
       nextPageToken = response.nextPageToken;
       if (nextPageToken == null || nextPageToken.length === 0) break;

packages/client/src/workflow-client.ts

@@ -12,7 +12,7 @@
   "author": "Temporal Technologies Inc. <sdk@temporal.io>",
   "license": "MIT",
   "dependencies": {
-    "@opentelemetry/api": "^1.3.0",
+    "@opentelemetry/api": "^1.4.1",
     "@temporalio/proto": "file:../proto",
     "long": "^5.2.0",
     "ms": "^2.1.3",

packages/common/package.json

@@ -8,7 +8,7 @@ export const encodingTypes = {
   METADATA_ENCODING_PROTOBUF_JSON: 'json/protobuf',
   METADATA_ENCODING_PROTOBUF: 'binary/protobuf',
 } as const;
-export type EncodingType = typeof encodingTypes[keyof typeof encodingTypes];
+export type EncodingType = (typeof encodingTypes)[keyof typeof encodingTypes];
 
 export const encodingKeys = {
   METADATA_ENCODING_NULL: encode(encodingTypes.METADATA_ENCODING_NULL),

packages/common/src/converter/types.ts

@@ -22,7 +22,7 @@
   "author": "Temporal Technologies Inc. <sdk@temporal.io>",
   "license": "MIT",
   "dependencies": {
-    "@opentelemetry/api": "^1.3.0",
+    "@opentelemetry/api": "^1.4.1",
     "@temporalio/common": "file:../common",
     "arg": "^5.0.2",
     "cargo-cp-artifact": "^0.1.6",

packages/core-bridge/package.json

@@ -14,10 +14,10 @@
   "author": "Temporal Technologies Inc. <sdk@temporal.io>",
   "license": "MIT",
   "dependencies": {
-    "@opentelemetry/api": "^1.3.0",
-    "@opentelemetry/core": "^1.8.0",
-    "@opentelemetry/resources": "^1.8.0",
-    "@opentelemetry/sdk-trace-base": "^1.8.0",
+    "@opentelemetry/api": "^1.4.1",
+    "@opentelemetry/core": "^1.12.0",
+    "@opentelemetry/resources": "^1.12.0",
+    "@opentelemetry/sdk-trace-base": "^1.12.0",
     "@temporalio/activity": "file:../activity",
     "@temporalio/client": "file:../client",
     "@temporalio/common": "file:../common",

packages/interceptors-opentelemetry/package.json

@@ -19,6 +19,9 @@ export interface SerializableSpan {
   readonly events: tracing.TimedEvent[];
   readonly duration: otel.HrTime;
   readonly ended: boolean;
+  readonly droppedAttributesCount: number;
+  readonly droppedLinksCount: number;
+  readonly droppedEventsCount: number;
   // readonly resource: Resource;
   // eslint-disable-next-line deprecation/deprecation
   readonly instrumentationLibrary: InstrumentationLibrary;

packages/interceptors-opentelemetry/src/workflow/definitions.ts

@@ -29,6 +29,9 @@ export class SpanExporter implements tracing.SpanExporter {
       events: span.events,
       duration: span.duration,
       ended: span.ended,
+      droppedAttributesCount: span.droppedAttributesCount,
+      droppedEventsCount: span.droppedEventsCount,
+      droppedLinksCount: span.droppedLinksCount,
       instrumentationLibrary: span.instrumentationLibrary,
     };
   }

packages/interceptors-opentelemetry/src/workflow/span-exporter.ts

@@ -28,11 +28,11 @@
   "dependencies": {
     "@grpc/grpc-js": "~1.7.3",
     "@grpc/proto-loader": "^0.7.0",
-    "@opentelemetry/api": "^1.3.0",
-    "@opentelemetry/core": "^1.8.0",
-    "@opentelemetry/exporter-trace-otlp-grpc": "^0.34.0",
-    "@opentelemetry/sdk-node": "^0.34.0",
-    "@opentelemetry/semantic-conventions": "^1.8.0",
+    "@opentelemetry/api": "^1.4.1",
+    "@opentelemetry/core": "^1.12.0",
+    "@opentelemetry/exporter-trace-otlp-grpc": "^0.38.0",
+    "@opentelemetry/sdk-node": "^0.38.0",
+    "@opentelemetry/semantic-conventions": "^1.12.0",
     "@temporalio/activity": "file:../activity",
     "@temporalio/client": "file:../client",
     "@temporalio/common": "file:../common",

packages/test/package.json

@@ -13,7 +13,7 @@
   "author": "Temporal Technologies Inc. <sdk@temporal.io>",
   "license": "MIT",
   "dependencies": {
-    "@opentelemetry/api": "^1.3.0",
+    "@opentelemetry/api": "^1.4.1",
     "@swc/core": "^1.2.204",
     "@temporalio/activity": "file:../activity",
     "@temporalio/client": "file:../client",

packages/worker/package.json

@@ -83,7 +83,7 @@ function formatCallsiteName(callsite: NodeJS.CallSite): string | null {
  */
 export function injectConsole(context: vm.Context): void {
   const consoleMethods = ['log', 'warn', 'error', 'info', 'debug'] as const;
-  type ConsoleMethod = typeof consoleMethods[number];
+  type ConsoleMethod = (typeof consoleMethods)[number];
   function makeConsoleFn(level: ConsoleMethod) {
     return function (...args: unknown[]) {
       const { info } = context.__TEMPORAL_ACTIVATOR__;