Merge pull request #40 from golemfactory/feature/critical-error-event

feat: critical error event in task executor
golemfactory · Mar 13, 2024 · 36af5ee · 36af5ee
2 parents 766b719 + 272b30e
commit 36af5ee
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/events.ts b/src/events.ts
@@ -20,6 +20,11 @@ export interface TaskExecutorEventsDict {
    */
   beforeEnd: (timestamp: number) => void;
 
+  /**
+   * Fires when task executor encountered an unrecoverable error and is about to shut down.
+   */
+  criticalError: (err: Error) => void;
+
   /**
    * Fires when task executor is completely terminated.
    */

diff --git a/src/executor.ts b/src/executor.ts
@@ -472,6 +472,7 @@ export class TaskExecutor {
   }
 
   private handleCriticalError(err: Error) {
+    this.events.emit("criticalError", err);
     const message =
       "TaskExecutor faced a critical error and will now cancel work, terminate agreements and request settling payments";
     this.logger.error(message, err);