feat(sdk-metrics): PeriodicExportingMetricReader now flushes pending …

…tasks at shutdown (#5242)

CHANGELOG.md

@@ -13,6 +13,8 @@ For semantic convention package changes, see the [semconv CHANGELOG](packages/se
 
 ### :rocket: (Enhancement)
 
+* feat(sdk-metrics): PeriodicExportingMetricReader now flushes pending tasks at shutdown [#5242](https://github.com/open-telemetry/opentelemetry-js/pull/5242)
+
 ### :bug: (Bug Fix)
 
 * fix(sdk-trace-base): do not load OTEL_ env vars on module load, but when needed [#5224](https://github.com/open-telemetry/opentelemetry-js/pull/5224)

experimental/packages/opentelemetry-exporter-metrics-otlp-http/test/node/OTLPMetricExporter.test.ts

@@ -214,8 +214,9 @@ describe('OTLPMetricExporter', () => {
       meterProvider.getMeter('test-meter').createCounter('test-counter').add(1);
 
       // act
-      meterProvider.forceFlush();
-      meterProvider.shutdown();
+      meterProvider.forceFlush().then(() => {
+        return meterProvider.shutdown();
+      });
     });
   });
 });

packages/sdk-metrics/src/MeterProvider.ts

@@ -122,7 +122,7 @@ export class MeterProvider implements IMeterProvider {
   }
 
   /**
-   * Flush all buffered data and shut down the MeterProvider and all registered
+   * Shut down the MeterProvider and all registered
    * MetricReaders.
    *
    * Returns a promise which is resolved when all flushes are complete.

packages/sdk-metrics/src/export/PeriodicExportingMetricReader.ts

@@ -161,7 +161,7 @@ export class PeriodicExportingMetricReader extends MetricReader {
     if (this._interval) {
       clearInterval(this._interval);
     }
-
+    await this.onForceFlush();
     await this._exporter.shutdown();
   }
 }

packages/sdk-metrics/test/MeterProvider.test.ts

@@ -126,9 +126,9 @@ describe('MeterProvider', () => {
       assert.strictEqual(meter1, meter2);
     });
 
-    it('get a noop meter on shutdown', () => {
+    it('get a noop meter on shutdown', async () => {
       const meterProvider = new MeterProvider();
-      meterProvider.shutdown();
+      await meterProvider.shutdown();
       const meter = meterProvider.getMeter('meter1', '1.0.0');
       // returned tracer should be no-op, not instance of Meter (from SDK)
       assert.ok(!(meter instanceof Meter));

packages/sdk-metrics/test/export/PeriodicExportingMetricReader.test.ts

@@ -77,9 +77,7 @@ class TestMetricExporter implements PushMetricExporter {
 
   async shutdown(): Promise<void> {
     if (this._shutdown) return;
-    const flushPromise = this.forceFlush();
     this._shutdown = true;
-    await flushPromise;
   }
 
   async forceFlush(): Promise<void> {