Module pipeline_executor 

Composable pipeline executor for build-graph operations Composable pipeline executor for GraphRAG operations

Provides a step-by-step interface for building knowledge graphs, giving callers control over individual pipeline phases.

Example

use graphrag_core::pipeline_executor::PipelineExecutor;
use graphrag_core::GraphRAG;

let mut graphrag = GraphRAG::builder()
    .with_output_dir("./output")
    .with_hash_embeddings()
    .build()?;

let executor = PipelineExecutor::new(&mut graphrag);
let report = executor.run_full_pipeline().await?;

println!("Pipeline complete: {} entities, {} relationships",
    report.entity_count, report.relationship_count);

Structs

PipelineExecutor

Composable pipeline executor

PipelineReport

Report produced after a pipeline run