diff --git a/apps/coordinator/src/index.ts b/apps/coordinator/src/index.ts index cfcb24ba34..d6efc95765 100644 --- 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; }