Function reth_cli_commands::import::build_import_pipeline

pub fn build_import_pipeline<N, C, E>(
    config: &Config,
    provider_factory: ProviderFactory<N>,
    consensus: &Arc<C>,
    file_client: Arc<FileClient>,
    static_file_producer: StaticFileProducer<ProviderFactory<N>>,
    disable_exec: bool,
    executor: E,
) -> Result<(Pipeline<N>, impl Stream<Item = NodeEvent>)>
where
    N: NodeTypesWithDB<ChainSpec = ChainSpec>,
    C: Consensus + 'static,
    E: BlockExecutorProvider,

Builds import pipeline.

If configured to execute, all stages will run. Otherwise, only stages that don’t require state will run.