Method buildExecutionPipeline

apps/sim/executor/execution/executor.ts:347–385

(
    context: ExecutionContext,
    dag: DAG,
    state: ExecutionState,
    snapshotState = this.contextExtensions.snapshotState
  )

  }

  private buildExecutionPipeline(
    context: ExecutionContext,
    dag: DAG,
    state: ExecutionState,
    snapshotState = this.contextExtensions.snapshotState
  ) {
    const resolver = new VariableResolver(this.workflow, this.workflowVariables, state, {
      navigatePathAsync,
    })
    const allHandlers = createBlockHandlers()
    const blockExecutor = new BlockExecutor(allHandlers, resolver, this.contextExtensions, state)
    const edgeManager = new EdgeManager(dag)
    const loopOrchestrator = new LoopOrchestrator(
      dag,
      state,
      resolver,
      this.contextExtensions,
      edgeManager
    )
    const parallelOrchestrator = new ParallelOrchestrator(
      dag,
      state,
      resolver,
      this.contextExtensions,
      edgeManager
    )
    edgeManager.restoreDeactivatedEdges(
      snapshotState?.deactivatedEdges,
      snapshotState?.nodesWithActivatedEdge
    )
    const nodeOrchestrator = new NodeExecutionOrchestrator(
      dag,
      state,
      blockExecutor,
      loopOrchestrator,
      parallelOrchestrator
    )
    return new ExecutionEngine(context, dag, edgeManager, nodeOrchestrator)
  }

  private createExecutionContext(
    workflowId: string,