checkpoint test is docker specific
This commit is contained in:
@@ -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);
|
||||
|
||||
@@ -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);
|
||||
|
||||
@@ -15,7 +15,7 @@ export type CheckpointTestResult =
|
||||
error?: unknown;
|
||||
};
|
||||
|
||||
export async function testCheckpointSupport(): Promise<CheckpointTestResult> {
|
||||
export async function testDockerCheckpoint(): Promise<CheckpointTestResult> {
|
||||
try {
|
||||
// Create a dummy container
|
||||
const container =
|
||||
|
||||
Reference in New Issue
Block a user