Function runRenderBatch

packages/cli/src/commands/cloudrun.ts:597–692

(args: Record<string, unknown>)

 */
// fallow-ignore-next-line complexity
async function runRenderBatch(args: Record<string, unknown>): Promise<void> {
  const projectDir = args.target as string | undefined;
  const batchPath = args.batch as string | undefined;
  if (!projectDir || !batchPath) {
    console.error(
      "[cloudrun render-batch] usage: hyperframes cloudrun render-batch <projectDir> --batch <file.jsonl> --width <px> --height <px>",
    );
    process.exit(1);
  }
  const width = parsePositiveInt(args.width, "--width");
  const height = parsePositiveInt(args.height, "--height");
  if (width === undefined || height === undefined) {
    console.error("[cloudrun render-batch] --width and --height are required.");
    process.exit(1);
  }
  const fps = parseIntFlag(args.fps) ?? 30;
  if (fps !== 24 && fps !== 30 && fps !== 60) {
    console.error(`[cloudrun render-batch] --fps must be 24, 30, or 60; got ${fps}.`);
    process.exit(1);
  }
  if (!existsSync(resolve(batchPath))) {
    console.error(`[cloudrun render-batch] batch file not found: ${batchPath}`);
    process.exit(1);
  }
  const entries = parseBatchFile(resolve(batchPath));
  if (entries.length === 0) {
    console.error("[cloudrun render-batch] batch file has no entries.");
    process.exit(1);
  }

  const dryRun = Boolean(args["dry-run"]);
  if (dryRun) {
    const manifest = entries.map((e, i) => ({
      line: i + 1,
      outputKey: e.outputKey,
      status: "would-start",
    }));
    console.log(JSON.stringify(manifest, null, 2));
    return;
  }

  const state = readState(args);
  const maxConcurrent =
    parsePositiveInt(args["max-concurrent"], "--max-concurrent") ?? DEFAULT_BATCH_MAX_CONCURRENT;
  const { deploySite, renderToCloudRun } = await import("@hyperframes/gcp-cloud-run/sdk");

  // Upload the project once; every entry reuses the same content-addressed
  // site handle so the tar+upload cost is paid a single time.
  const siteHandle = await deploySite({
    projectDir: resolve(projectDir),
    bucketName: state.bucketName,
    siteId: args["site-id"] as string | undefined,
  });

  const results: Array<{ outputKey: string; executionName?: string; error?: string }> = [];
  // Start executions in fixed-size waves so we never exceed `maxConcurrent`
  // in-flight CreateExecution calls.
  for (let i = 0; i < entries.length; i += maxConcurrent) {