Update

open-telemetry · Dec 14, 2023 · 0d1a1d3 · 0d1a1d3
1 parent 6bbbb1e
commit 0d1a1d3
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 14 deletions.
diff --git a/experimental/packages/sdk-logs/src/export/BatchLogRecordProcessorBase.ts b/experimental/packages/sdk-logs/src/export/BatchLogRecordProcessorBase.ts
@@ -178,9 +178,7 @@ export abstract class BatchLogRecordProcessorBase<T extends BufferConfig>
             );
           }
         })
-        .catch(error => {
-          globalErrorHandler(error);
-        });
+        .catch(globalErrorHandler);
 
     const pendingResources = logRecords
       .map(logRecord => logRecord.resource)
@@ -192,9 +190,7 @@ export abstract class BatchLogRecordProcessorBase<T extends BufferConfig>
     } else {
       return Promise.all(
         pendingResources.map(resource => resource.waitForAsyncAttributes?.())
-      ).then(doExport, err => {
-        globalErrorHandler(err);
-      });
+      ).then(doExport, globalErrorHandler);
     }
   }
 

diff --git a/experimental/packages/sdk-logs/src/export/SimpleLogRecordProcessor.ts b/experimental/packages/sdk-logs/src/export/SimpleLogRecordProcessor.ts
@@ -52,22 +52,19 @@ export class SimpleLogRecordProcessor implements LogRecordProcessor {
             );
           }
         })
-        .catch(error => {
-          globalErrorHandler(error);
-        });
+        .catch(globalErrorHandler);
 
     // Avoid scheduling a promise to make the behavior more predictable and easier to test
     if (logRecord.resource.asyncAttributesPending) {
-      const exportPromise = logRecord.resource.waitForAsyncAttributes?.().then(
-        () => {
+      const exportPromise = logRecord.resource
+        .waitForAsyncAttributes?.()
+        .then(() => {
           // Using TS Non-null assertion operator because exportPromise could not be null in here
           // if waitForAsyncAttributes is not present this code will never be reached
           // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
           this._unresolvedExports.delete(exportPromise!);
           return doExport();
-        },
-        err => globalErrorHandler(err)
-      );
+        }, globalErrorHandler);
 
       // store the unresolved exports
       if (exportPromise != null) {