dlin-core 0.2.2

Core library for dbt model lineage analysis
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

use super::*;
use crate::parser::discovery::DiscoveredFiles;
use std::fs;
use std::path::PathBuf;

fn setup_temp_project() -> (tempfile::TempDir, PathBuf) {
    let tmp = tempfile::tempdir().unwrap();
    let project_dir = tmp.path().to_path_buf();

    // Create model files
    let models_dir = project_dir.join("models");
    fs::create_dir_all(&models_dir).unwrap();

    fs::write(
        models_dir.join("stg_orders.sql"),
        "SELECT * FROM {{ source('raw', 'orders') }}",
    )
    .unwrap();

    fs::write(
        models_dir.join("orders.sql"),
        "SELECT * FROM {{ ref('stg_orders') }}",
    )
    .unwrap();

    // Create schema YAML with source definition
    fs::write(
        models_dir.join("schema.yml"),
        r#"
version: 2
sources:
  - name: raw
    tables:
      - name: orders
        description: "Raw orders table"
models:
  - name: stg_orders
    description: "Staged orders"
"#,
    )
    .unwrap();

    (tmp, project_dir)
}

mod build_graph;
mod generic_tests;
mod ref_parsing;
mod versioned;