Function runWorkflowWithScheduler

worker/src/temporal/workflow-scheduler.ts:48–214

(
  definition: WorkflowDefinition,
  options: WorkflowSchedulerOptions,
)

}

export async function runWorkflowWithScheduler(
  definition: WorkflowDefinition,
  options: WorkflowSchedulerOptions,
): Promise<void> {
  const { run, onNodeSkipped } = options;

  // Map sourceRef -> List of Edges (preserving handle info)
  const successEdges = new Map<string, WorkflowEdge[]>();
  const failureDependents = new Map<string, string[]>();

  const successParentsMap = new Map<string, Set<string>>();
  const failureParentsMap = new Map<string, Set<string>>();

  for (const edge of definition.edges ?? []) {
    if (edge.kind === 'error') {
      const children = failureDependents.get(edge.sourceRef) ?? [];
      children.push(edge.targetRef);
      failureDependents.set(edge.sourceRef, children);

      const parents = failureParentsMap.get(edge.targetRef) ?? new Set<string>();
      parents.add(edge.sourceRef);
      failureParentsMap.set(edge.targetRef, parents);
    } else {
      const edges = successEdges.get(edge.sourceRef) ?? [];
      edges.push(edge);
      successEdges.set(edge.sourceRef, edges);

      const parents = successParentsMap.get(edge.targetRef) ?? new Set<string>();
      parents.add(edge.sourceRef);
      successParentsMap.set(edge.targetRef, parents);
    }
  }

  const nodeStates = new Map<string, NodeState>();
  const readyQueue: ReadyItem[] = [];
  const pending = new Set<string>();

  for (const action of definition.actions) {
    pending.add(action.ref);

    const successParents = new Set(successParentsMap.get(action.ref) ?? []);
    const failureParents = new Set(failureParentsMap.get(action.ref) ?? []);

    const metadata = definition.nodes?.[action.ref];
    const strategy: WorkflowJoinStrategy | 'all' = metadata?.joinStrategy ?? 'all';

    const state: NodeState = {
      strategy,
      successParents,
      skippedParents: new Set(),
      failureParents,
      triggeredBySuccess: successParents.size === 0,
      failureTriggered: false,
      skipped: false,
      totalSuccessParents: successParents.size,
    };

    nodeStates.set(action.ref, state);