diff --git a/packages/producer/src/services/render/stages/captureStreamingStage.test.ts b/packages/producer/src/services/render/stages/captureStreamingStage.test.ts
index df3e87c19..96b84e6a6 100644
--- a/packages/producer/src/services/render/stages/captureStreamingStage.test.ts
+++ b/packages/producer/src/services/render/stages/captureStreamingStage.test.ts
@@ -240,11 +240,11 @@ describe("runCaptureStreamingStage", () => {
     process.env.HF_DE_STALL_MS = "50";
     const { runCaptureStreamingStage } = await import("./captureStreamingStage.js");
     const cfg = { forceScreenshot: false, ffmpegStreamingTimeout: 3_600_000 };
+    const baseInput = createInput(cfg);
     const input = {
-      ...createInput(cfg),
+      ...baseInput,
       totalFrames: 100,
-      workerCount: 2,
-      forceParallelStream: true,
+      plan: { ...baseInput.plan, workerCount: 2, forceParallelStream: true },
     };
 
     let caught: unknown;
@@ -274,11 +274,11 @@ describe("runCaptureStreamingStage", () => {
     const controller = new AbortController();
     const { runCaptureStreamingStage } = await import("./captureStreamingStage.js");
     const cfg = { forceScreenshot: false, ffmpegStreamingTimeout: 3_600_000 };
+    const baseInput = createInput(cfg);
     const input = {
-      ...createInput(cfg),
+      ...baseInput,
       totalFrames: 100,
-      workerCount: 2,
-      forceParallelStream: true,
+      plan: { ...baseInput.plan, workerCount: 2, forceParallelStream: true },
       abortSignal: controller.signal,
     };