github-featured/triggerdotdev--trigger.dev
2
0
Fork 0
Code Issues Pull Requests Deployments Models Agent Notes Packages Projects Releases Wiki Activity

exit process after checkpointing

Browse Source
This commit is contained in:
nicktrn
2024-03-20 14:38:21 +00:00
parent 84250a6f9e
commit 18bd7f4623
1 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/coordinator/src/index.ts
+21
View File
@@ -502,9 +502,12 @@ class TaskCoordinator {
reason: {
type: "RETRYING_AFTER_FAILURE",
attemptNumber: execution.attempt.number,
// TODO: attach completion data here
},
});
// TODO: replace this with
// callback({ didCheckpoint: true, shouldExit: false });
confirmCompletion({ didCheckpoint: true, shouldExit: false });
});
@@ -537,6 +540,12 @@ class TaskCoordinator {
return;
}
if (!checkpoint.docker) {
socket.emit("REQUEST_EXIT", {
version: "v1",
});
}
this.#platformSocket?.send("CHECKPOINT_CREATED", {
version: "v1",
attemptId: socket.data.attemptId,
@@ -573,6 +582,12 @@ class TaskCoordinator {
return;
}
if (!checkpoint.docker) {
socket.emit("REQUEST_EXIT", {
version: "v1",
});
}
this.#platformSocket?.send("CHECKPOINT_CREATED", {
version: "v1",
attemptId: socket.data.attemptId,
@@ -609,6 +624,12 @@ class TaskCoordinator {
return;
}
if (!checkpoint.docker) {
socket.emit("REQUEST_EXIT", {
version: "v1",
});
}
this.#platformSocket?.send("CHECKPOINT_CREATED", {
version: "v1",
attemptId: socket.data.attemptId,