triggerdotdev
diff --git a/Collapse file
‎packages/core/src/v3/otel/tracingSDK.ts‎
Copy file name to clipboardExpand all lines: packages/core/src/v3/otel/tracingSDK.ts
+10Lines changed: 10 additions & 0 deletions b/Collapse file
‎packages/core/src/v3/otel/tracingSDK.ts‎
Copy file name to clipboardExpand all lines: packages/core/src/v3/otel/tracingSDK.ts
+10Lines changed: 10 additions & 0 deletions
@@ -375,11 +375,16 @@ export class TracingSDK {
       this._meterProvider.forceFlush(),
     ]);
     const providerNames = ["trace", "log", "meter"] as const;
+    const errors: Error[] = [];
     results.forEach((result, index) => {
       if (result.status === "rejected") {
         console.error(`Failed to flush ${providerNames[index]} provider:`, result.reason);
+        errors.push(result.reason instanceof Error ? result.reason : new Error(String(result.reason)));
       }
     });
+    if (errors.length > 0) {
+      throw new AggregateError(errors, "One or more providers failed to flush");
+    }
   }
 
   public async shutdown() {
@@ -389,11 +394,16 @@ export class TracingSDK {
       this._meterProvider.shutdown(),
     ]);
     const providerNames = ["trace", "log", "meter"] as const;
+    const errors: Error[] = [];
     results.forEach((result, index) => {
       if (result.status === "rejected") {
         console.error(`Failed to shutdown ${providerNames[index]} provider:`, result.reason);
+        errors.push(result.reason instanceof Error ? result.reason : new Error(String(result.reason)));
       }
     });
+    if (errors.length > 0) {
+      throw new AggregateError(errors, "One or more providers failed to shutdown");
+    }
   }
 }