Function handleSkip

worker/src/temporal/workflow-scheduler.ts:339–372

(
  ref: string,
  readyQueue: ReadyItem[],
  pending: Set<string>,
  nodeStates: Map<string, NodeState>,
  successEdges: Map<string, WorkflowEdge[]>,
  onNodeSkipped?: (ref: string) => Promise<void>,
)

}

async function handleSkip(
  ref: string,
  readyQueue: ReadyItem[],
  pending: Set<string>,
  nodeStates: Map<string, NodeState>,
  successEdges: Map<string, WorkflowEdge[]>,
  onNodeSkipped?: (ref: string) => Promise<void>,
) {
  if (!pending.has(ref)) return;

  pending.delete(ref);
  const state = nodeStates.get(ref);
  if (state) state.skipped = true;

  if (onNodeSkipped) {
    await onNodeSkipped(ref);
  }

  const edges = successEdges.get(ref) ?? [];
  const children = new Set(edges.map((e) => e.targetRef));

  for (const child of children) {
    await processChild(
      child,
      ref,
      'skipped',
      readyQueue,
      pending,
      nodeStates,
      successEdges,
      onNodeSkipped,
    );
  }
}

async function handleFailure(
  ref: string,