handle all coordinator errors

2024-06-05 08:52:18 +01:00
parent 4541f2e004
commit 34c896e6b4
1 changed files with 16 additions and 0 deletions
@@ -946,6 +946,14 @@ class TaskCoordinator {
            socket.data.attemptFriendlyId = executionAck.payload.execution.attempt.id;
          } catch (error) {
            logger.error("Error", { error });
+
+            await crashRun({
+              name: "ReadyForExecutionError",
+              message:
+                error instanceof Error ? `Unexpected error: ${error.message}` : "Unexpected error",
+            });
+
+            return;
          }
        });

@@ -986,6 +994,14 @@ class TaskCoordinator {
            });
          } catch (error) {
            logger.error("Error", { error });
+
+            await crashRun({
+              name: "ReadyForLazyAttemptError",
+              message:
+                error instanceof Error ? `Unexpected error: ${error.message}` : "Unexpected error",
+            });
+
+            return;
          }
        });