From 81ca34a8474b629f03a1884ac3001ac8e6ceedfc Mon Sep 17 00:00:00 2001 From: nicktrn <55853254+nicktrn@users.noreply.github.com> Date: Wed, 5 Jun 2024 13:27:30 +0100 Subject: [PATCH] checkpoint test is docker specific --- apps/coordinator/src/index.ts | 4 ++-- apps/docker-provider/src/index.ts | 4 ++-- packages/core-apps/src/checkpoints.ts | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/apps/coordinator/src/index.ts b/apps/coordinator/src/index.ts index a5dc7b419..3de269513 100644 --- a/apps/coordinator/src/index.ts +++ b/apps/coordinator/src/index.ts @@ -16,7 +16,7 @@ import { HttpReply, getTextBody, SimpleLogger, - testCheckpointSupport, + testDockerCheckpoint, } from "@trigger.dev/core-apps"; import { ExponentialBackoff } from "./backoff"; @@ -138,7 +138,7 @@ class Checkpointer { this.#logger.log(`${this.#dockerMode ? "Docker" : "Kubernetes"} mode`); if (this.#dockerMode) { - const testCheckpoint = await testCheckpointSupport(); + const testCheckpoint = await testDockerCheckpoint(); if (testCheckpoint.ok) { return this.#getInitReturn(true); diff --git a/apps/docker-provider/src/index.ts b/apps/docker-provider/src/index.ts index e41449f3e..d339b5a93 100644 --- a/apps/docker-provider/src/index.ts +++ b/apps/docker-provider/src/index.ts @@ -7,7 +7,7 @@ import { TaskOperationsCreateOptions, TaskOperationsIndexOptions, isExecaChildProcess, - testCheckpointSupport, + testDockerCheckpoint, } from "@trigger.dev/core-apps"; import { setTimeout } from "node:timers/promises"; import { PostStartCauses, PreStopCauses } from "@trigger.dev/core/v3"; @@ -43,7 +43,7 @@ class DockerTaskOperations implements TaskOperations { logger.log("Initializing task operations"); - const testCheckpoint = await testCheckpointSupport(); + const testCheckpoint = await testDockerCheckpoint(); if (testCheckpoint.ok) { return this.#getInitReturn(true); diff --git a/packages/core-apps/src/checkpoints.ts b/packages/core-apps/src/checkpoints.ts index 6f079181d..039a0bd16 100644 --- a/packages/core-apps/src/checkpoints.ts +++ b/packages/core-apps/src/checkpoints.ts @@ -15,7 +15,7 @@ export type CheckpointTestResult = error?: unknown; }; -export async function testCheckpointSupport(): Promise { +export async function testDockerCheckpoint(): Promise { try { // Create a dummy container const container =