fix(render): scale timeout for long video encodes (#2244)

Author: miguel-heygen

packages/producer/src/services/render/stages/encodeStage.test.ts

@@ -154,6 +154,24 @@ describe("gif encode args", () => {
 });
 
 describe("runEncodeStage config plumbing", () => {
+  it("scales the encode timeout for long compositions", async () => {
+    const { runEncodeStage } = await import("./encodeStage.js");
+
+    await runEncodeStage(
+      makeInput({
+        job: {
+          ...makeInput().job,
+          duration: 754.8,
+        },
+        engineConfig: { ffmpegEncodeTimeout: 600_000 },
+      }),
+    );
+
+    expect(encodeFramesFromDirMock.mock.calls[0]?.[5]).toEqual({
+      ffmpegEncodeTimeout: 3_019_200,
+    });
+  });
+
   it("prefers engine config supplied by the orchestrator", async () => {
     const { runEncodeStage } = await import("./encodeStage.js");
     const orchestratorEngineConfig = { ffmpegEncodeTimeout: 54_321 };

packages/producer/src/services/render/stages/encodeStage.ts

@@ -277,6 +277,16 @@ export async function runEncodeStage(input: EncodeStageInput): Promise<EncodeSta
   // ── Stage 5: Encode ───────────────────────────────────────────────
   updateJobStatus(job, "encoding", "Encoding video", 75, onProgress);
 
+  // ffmpegEncodeTimeout is a total wall-clock cap, not an inactivity timeout.
+  // A fixed ten-minute cap reliably kills long high-quality disk-frame encodes
+  // that are still making progress. Preserve larger operator overrides while
+  // guaranteeing four seconds of encode budget per second of source video.
+  const scaledEncodeTimeout = Math.ceil((job.duration ?? 0) * 4_000);
+  const videoEngineCfg =
+    scaledEncodeTimeout > engineCfg.ffmpegEncodeTimeout
+      ? { ...engineCfg, ffmpegEncodeTimeout: scaledEncodeTimeout }
+      : engineCfg;
+
   const frameExt = needsAlpha ? "png" : "jpg";
   const framePattern = `frame_%06d.${frameExt}`;
   const encoderOpts = {
@@ -305,15 +315,15 @@ export async function runEncodeStage(input: EncodeStageInput): Promise<EncodeSta
         encoderOpts,
         chunkedEncodeSize,
         abortSignal,
-        engineCfg,
+        videoEngineCfg,
       )
     : await encodeFramesFromDir(
         framesDir,
         framePattern,
         videoOnlyPath,
         encoderOpts,
         abortSignal,
-        engineCfg,
+        videoEngineCfg,
       );
   assertNotAborted();