Struct ModelDag 

pub struct ModelDag {
    pub graph: DiGraph<ModelNode, ()>,
    pub node_map: HashMap<String, NodeIndex>,
}

Complete pipeline DAG with topological execution tiering and cycle detection.

Fields

graph: DiGraph<ModelNode, ()>

node_map: HashMap<String, NodeIndex>

Implementations

impl ModelDag

pub fn new() -> Self

pub fn add_model( &mut self, name: impl Into<String>, raw_sql: &str, materialization: Materialization, catalog_prefix: &str, ) -> Result<NodeIndex>

Registers a raw model SQL definition into the DAG with a default Parquet format.

pub fn add_model_with_format( &mut self, name: impl Into<String>, raw_sql: &str, materialization: Materialization, output_format: OutputFormat, output_path: Option<String>, catalog_prefix: &str, ) -> Result<NodeIndex>

Registers a raw model SQL definition with explicit OutputFormat and optional output path.

pub fn build_graph(&mut self) -> Result<()>

Resolves dependency edges between models and validates that there are no circular dependencies or layer boundary violations.

pub fn topological_sequence(&self) -> Result<Vec<ModelNode>>

Computes a flat topologically sorted execution sequence.

pub fn execution_tiers(&self) -> Result<Vec<Vec<ModelNode>>>

Computes parallel execution tiers where all models in a tier can be run concurrently.

pub fn primary_source(node: &ModelNode) -> Option<(&str, &str)>

First source('ns','table') dependency, if any.

pub fn bronze_source_ident(node: &ModelNode) -> Option<(String, String)>

Resolve registration identity for a bronze-backed model.

pub fn validate_bronze_sources( &self, project_dir: &Path, mode: BronzeCheckMode, ) -> Result<BronzeValidationReport>

Compile-time bronze frontmatter / scan_path validation.

• Off — no filesystem checks
• Warn — missing paths become warnings
• Fail — missing paths become errors (report.has_errors())

pub fn validate_bronze_sources_with_roots( &self, project_dir: &Path, mode: BronzeCheckMode, roots: &HashMap<String, String>, ) -> Result<BronzeValidationReport>

Compile-time bronze checks with project roots: for $name path templates.

impl ModelDag

pub fn resolve_select( &self, select: Option<&str>, mode: SelectMode, ) -> Result<HashSet<String>>

Resolve which model names are in the selection.

pub fn subgraph(&self, keep: &HashSet<String>) -> Result<ModelDag>

Return a new DAG containing only keep models (must include all model deps).

pub fn apply_select( &self, select: Option<&str>, mode: SelectMode, ) -> Result<ModelDag>

Apply --select and return a filtered DAG.

pub fn models_with_test_contract(&self) -> Result<Vec<String>>

Names of models that declare a test contract (for default rbt test).

Trait Implementations

impl Debug for ModelDag

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ModelDag

fn default() -> ModelDag

Returns the “default value” for a type.