Function runWithTrace

worker/src/temporal/__tests__/workflow-runner.test.ts:362–404

(runId: string)

    });

    const runWithTrace = async (runId: string) => {
      const events: TraceEvent[] = [];
      const trace = {
        record: (event: TraceEvent) => {
          events.push(event);
        },
      };

      const nodeIOStarts: NodeIOStartEvent[] = [];
      const nodeIOCompletions: NodeIOCompletionEvent[] = [];
      const nodeIO = {
        recordStart: async (data: NodeIOStartEvent) => {
          nodeIOStarts.push(data);
        },
        recordCompletion: async (data: NodeIOCompletionEvent) => {
          nodeIOCompletions.push(data);
        },
      };

      const result = await executeWorkflow(
        definition,
        {},
        {
          runId,
          trace,
          nodeIO,
        },
      );

      expect(result.success).toBe(true);

      // Validate node I/O was recorded for all nodes
      expect(nodeIOStarts).toHaveLength(4);
      expect(nodeIOCompletions).toHaveLength(4);
      expect(nodeIOCompletions.every((c) => c.status === 'completed')).toBe(true);

      // Validate merge node received correct input via node I/O
      const mergeCompletion = nodeIOCompletions.find((c) => c.nodeRef === 'merge');
      expect(mergeCompletion).toBeDefined();
      expect(mergeCompletion?.status).toBe('completed');

      return events.map(normalizeEvent);
    };

    const firstSequence = await runWithTrace('determinism-run-1');
    const secondSequence = await runWithTrace('determinism-run-2');