Function processChild

worker/src/temporal/workflow-scheduler.ts:285–337

(
  childRef: string,
  parentRef: string,
  type: 'fulfilled' | 'skipped',
  readyQueue: ReadyItem[],
  pending: Set<string>,
  nodeStates: Map<string, NodeState>,
  successEdges: Map<string, WorkflowEdge[]>,
  onNodeSkipped?: (ref: string) => Promise<void>,
)

}

async function processChild(
  childRef: string,
  parentRef: string,
  type: 'fulfilled' | 'skipped',
  readyQueue: ReadyItem[],
  pending: Set<string>,
  nodeStates: Map<string, NodeState>,
  successEdges: Map<string, WorkflowEdge[]>,
  onNodeSkipped?: (ref: string) => Promise<void>,
) {
  if (!pending.has(childRef)) return;

  const state = nodeStates.get(childRef);
  if (!state || state.failureTriggered || state.skipped) return;

  if (state.successParents.has(parentRef)) {
    state.successParents.delete(parentRef);

    if (type === 'skipped') {
      state.skippedParents.add(parentRef);
    }
  } else {
    // Already processed this parent
    return;
  }

  if (state.strategy === 'all') {
    if (state.successParents.size === 0) {
      if (state.skippedParents.size > 0) {
        // If 'all' strategy and at least one parent skipped, we skip.
        await handleSkip(childRef, readyQueue, pending, nodeStates, successEdges, onNodeSkipped);
      } else if (!state.triggeredBySuccess) {
        state.triggeredBySuccess = true;
        readyQueue.push({ ref: childRef, context: { joinStrategy: state.strategy } });
      }
    }
  } else {
    // ANY / FIRST
    if (type === 'fulfilled' && !state.triggeredBySuccess) {
      state.triggeredBySuccess = true;
      readyQueue.push({
        ref: childRef,
        context: { joinStrategy: state.strategy, triggeredBy: parentRef },
      });
    } else if (state.successParents.size === 0) {
      // All parents finished.
      // If we haven't been triggered yet, it means everything skipped.
      if (!state.triggeredBySuccess) {
        await handleSkip(childRef, readyQueue, pending, nodeStates, successEdges, onNodeSkipped);
      }
    }
  }
}

async function handleSkip(
  ref: string,