Resolve OTLP export failures instead of rejecting

packages/cli-kit/src/public/node/vendor/otel-js/export/InstantaneousMetricReader.test.ts

@@ -0,0 +1,48 @@
+import {InstantaneousMetricReader} from './InstantaneousMetricReader.js'
+import {ExportResultCode} from '@opentelemetry/core'
+import type {PushMetricExporter, ResourceMetrics} from '@opentelemetry/sdk-metrics'
+import {MeterProvider} from '@opentelemetry/sdk-metrics'
+import {describe, expect, test, vi} from 'vitest'
+
+function createMockExporter(resultCode: ExportResultCode, error?: Error): PushMetricExporter {
+  return {
+    export: vi.fn((_metrics: ResourceMetrics, callback: (result: {code: ExportResultCode; error?: Error}) => void) => {
+      callback({code: resultCode, error})
+    }),
+    forceFlush: vi.fn().mockResolvedValue(undefined),
+    shutdown: vi.fn().mockResolvedValue(undefined),
+  } as unknown as PushMetricExporter
+}
+
+function createReaderWithProvider(exporter: PushMetricExporter): {reader: InstantaneousMetricReader; provider: MeterProvider} {
+  const reader = new InstantaneousMetricReader({exporter, throttleLimit: 0})
+  const provider = new MeterProvider()
+  provider.addMetricReader(reader)
+  return {reader, provider}
+}
+
+describe('InstantaneousMetricReader', () => {
+  test('resolves on successful export', async () => {
+    const exporter = createMockExporter(ExportResultCode.SUCCESS)
+    const {reader, provider} = createReaderWithProvider(exporter)
+
+    await expect(reader.forceFlush()).resolves.toBeUndefined()
+    await provider.shutdown()
+  })
+
+  test('resolves without rejecting on export failure', async () => {
+    const exporter = createMockExporter(ExportResultCode.FAILED, new Error('Export failed with retryable status'))
+    const {reader, provider} = createReaderWithProvider(exporter)
+
+    await expect(reader.forceFlush()).resolves.toBeUndefined()
+    await provider.shutdown()
+  })
+
+  test('resolves without rejecting when export error is undefined', async () => {
+    const exporter = createMockExporter(ExportResultCode.FAILED)
+    const {reader, provider} = createReaderWithProvider(exporter)
+
+    await expect(reader.forceFlush()).resolves.toBeUndefined()
+    await provider.shutdown()
+  })
+})

packages/cli-kit/src/public/node/vendor/otel-js/export/InstantaneousMetricReader.ts

@@ -41,13 +41,12 @@ export class InstantaneousMetricReader extends MetricReader {
       diag.error('PeriodicExportingMetricReader: metrics collection errors', ...errors)
     }
 
-    return new Promise((resolve, reject) => {
+    return new Promise((resolve) => {
       this._exporter.export(resourceMetrics, (result) => {
-        if (result.code === ExportResultCode.SUCCESS) {
-          resolve()
-        } else {
-          reject(result.error ?? new Error(`InstantaneousMetricReader: metrics export failed (error ${result.error})`))
+        if (result.code !== ExportResultCode.SUCCESS) {
+          diag.error('InstantaneousMetricReader: metrics export failed', result.error)
         }
+        resolve()
       })
     })
   }

packages/cli-kit/src/public/node/vendor/otel-js/service/BaseOtelService/BaseOtelService.ts

@@ -136,8 +136,7 @@ export class BaseOtelService implements OtelService {
           instrument.add(finalValue, finalLabels)
         }
         // We flush metrics after every record - we do not await as we fire & forget.
-        // Catch any export errors to prevent unhandled rejections from crashing the CLI
-        void this.meterProvider.forceFlush({}).catch(() => {})
+        void this.meterProvider.forceFlush({})
       }
       record(firstValue, firstLabels)
       this.metrics.set(metricName, record)