Set the timeout for canceling checkpoints

triggerdotdev · May 13, 2024 · 1477a2e · 1477a2e
1 parent 2081cb1
commit 1477a2e
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 4 deletions.
diff --git a/.changeset/lazy-files-lay.md b/.changeset/lazy-files-lay.md
@@ -0,0 +1,5 @@
+---
+"@trigger.dev/core": patch
+---
+
+Increased the timeout when canceling a checkpoint to 31s (to match the timeout on the server)
diff --git a/packages/core/src/v3/runtime/prodRuntimeManager.ts b/packages/core/src/v3/runtime/prodRuntimeManager.ts
@@ -75,10 +75,14 @@ export class ProdRuntimeManager implements RuntimeManager {
     clock.reset();
 
     // The coordinator should cancel any in-progress checkpoints
-    const { checkpointCanceled, version } = await this.ipc.sendWithAck("CANCEL_CHECKPOINT", {
-      version: "v2",
-      reason: "WAIT_FOR_DURATION",
-    });
+    const { checkpointCanceled, version } = await this.ipc.sendWithAck(
+      "CANCEL_CHECKPOINT",
+      {
+        version: "v2",
+        reason: "WAIT_FOR_DURATION",
+      },
+      31_000
+    );
 
     if (checkpointCanceled) {
       // There won't be a checkpoint or external resume and we've already completed our internal timeout