Method #checkpointAndPush

apps/coordinator/src/index.ts:352–575

({
    runId,
    leaveRunning = true, // This mirrors kubernetes behaviour more accurately
    projectRef,
    deploymentVersion,
  }: CheckpointAndPushOptions)

  }

  async #checkpointAndPush({
    runId,
    leaveRunning = true, // This mirrors kubernetes behaviour more accurately
    projectRef,
    deploymentVersion,
  }: CheckpointAndPushOptions): Promise<CheckpointAndPushResult> {
    await this.initialize();

    const options = {
      runId,
      leaveRunning,
      projectRef,
      deploymentVersion,
    };

    if (!this.#dockerMode && !this.#canCheckpoint) {
      this.#logger.error("No checkpoint support. Simulation requires docker.");
      return { success: false, reason: "NO_SUPPORT" };
    }

    if (this.#abortControllers.has(runId)) {
      logger.error("Checkpoint procedure already in progress", { options });
      return { success: false, reason: "IN_PROGRESS" };
    }

    // This is a new checkpoint, clear any last failure for this run
    this.#clearFailedCheckpoint(runId);

    if (DISABLE_CHECKPOINT_SUPPORT) {
      this.#logger.error("Checkpoint support disabled", { options });
      return { success: false, reason: "DISABLED" };
    }

    const controller = new AbortController();
    this.#abortControllers.set(runId, controller);

    const $$ = $({ signal: controller.signal });

    const shortCode = nanoid(8);
    const imageRef = this.#getImageRef(projectRef, deploymentVersion, shortCode);
    const exportLocation = this.#getExportLocation(projectRef, deploymentVersion, shortCode);

    const cleanup = async () => {
      if (this.#dockerMode) {
        return;
      }

      try {
        await $`rm ${exportLocation}`;
        this.#logger.log("Deleted checkpoint archive", { exportLocation });

        await $`buildah rmi ${imageRef}`;
        this.#logger.log("Deleted checkpoint image", { imageRef });
      } catch (error) {
        this.#logger.error("Failure during checkpoint cleanup", { exportLocation, error });
      }
    };