Backport #3914: fix(world): accept lazy terminal run data - fix Zod schema for newer versions

.changeset/lazy-terminal-run-data.md

@@ -0,0 +1,6 @@
+---
+"@workflow/world": patch
+"@workflow/core": patch
+---
+
+Accept lazy completed and failed runs whose payload is represented by a remote reference.

packages/core/src/runtime/run.ts

@@ -291,7 +291,12 @@ export class Run<TResult> {
         }
 
         if (run.status === 'failed') {
-          throw new WorkflowRunFailedError(this.runId, run.error);
+          // Terminal run data can be returned lazily, so the error payload
+          // may not be materialized. Fall back to a generic message.
+          throw new WorkflowRunFailedError(
+            this.runId,
+            run.error ?? { message: 'Workflow run failed' }
+          );
         }
 
         throw new WorkflowRunNotCompletedError(this.runId, run.status);

packages/world/src/runs.test.ts

@@ -0,0 +1,27 @@
+import { describe, expect, it } from 'vitest';
+import { z } from 'zod';
+import { WorkflowRunSchema } from './runs.js';
+
+describe('WorkflowRunSchema', () => {
+  it('accepts terminal runs without materialized payloads', () => {
+    const completedSchema = WorkflowRunSchema.options[2];
+    const failedSchema = WorkflowRunSchema.options[3];
+    const run = {
+      runId: 'wrun_1',
+      deploymentId: 'dpl_1',
+      workflowName: 'workflow_1',
+      createdAt: new Date(),
+      updatedAt: new Date(),
+      completedAt: new Date(),
+    };
+
+    expect(completedSchema.shape.output).toBeInstanceOf(z.ZodOptional);
+    expect(failedSchema.shape.error).toBeInstanceOf(z.ZodOptional);
+    expect(
+      WorkflowRunSchema.safeParse({ ...run, status: 'completed' }).success
+    ).toBe(true);
+    expect(
+      WorkflowRunSchema.safeParse({ ...run, status: 'failed' }).success
+    ).toBe(true);
+  });
+});

packages/world/src/runs.ts

@@ -99,15 +99,15 @@ export const WorkflowRunSchema = z.discriminatedUnion('status', [
   // Completed state - output can be v1 or v2 format
   WorkflowRunBaseSchema.extend({
     status: z.literal('completed'),
-    output: SerializedDataSchema,
+    output: SerializedDataSchema.optional(),
     error: z.undefined().optional(),
     completedAt: z.coerce.date(),
   }),
   // Failed state
   WorkflowRunBaseSchema.extend({
     status: z.literal('failed'),
     output: z.undefined().optional(),
-    error: StructuredErrorSchema,
+    error: StructuredErrorSchema.optional(),
     completedAt: z.coerce.date(),
   }),
 ]);