If we’re keeping the run alive then set socket.data.requiresCheckpoin…

…tResumeWithMessage to undefined
triggerdotdev · Sep 18, 2024 · 0efed14 · 0efed14
1 parent 2dd5d46
commit 0efed14
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/apps/coordinator/src/index.ts b/apps/coordinator/src/index.ts
@@ -853,6 +853,7 @@ class TaskCoordinator {
           });
 
           if (ack?.keepRunAlive) {
+            socket.data.requiresCheckpointResumeWithMessage = undefined;
             logger.log("keeping run alive after task checkpoint", { runId: socket.data.runId });
             return;
           }
@@ -930,6 +931,7 @@ class TaskCoordinator {
           });
 
           if (ack?.keepRunAlive) {
+            socket.data.requiresCheckpointResumeWithMessage = undefined;
             logger.log("keeping run alive after batch checkpoint", { runId: socket.data.runId });
             return;
           }