vil_ai_compiler 0.4.0

AI pipeline compiler — compile RAG/agent workflows to optimized execution plans at build time
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

//! Semantic types for AI compiler operations.
//!
//! VIL process-oriented semantic model:
//! - Events: immutable audit records (Data Lane)
//! - Faults: error signals (Control Lane)
//! - State: mutable tracked state (Data Lane)

use serde::{Deserialize, Serialize};
use vil_macros::{VilAiEvent, VilAiFault, VilAiState};

// ── Events (Data Lane, immutable audit) ─────────────────────────────

/// Emitted after a pipeline compilation completes.
#[derive(Clone, Debug, Serialize, Deserialize, VilAiEvent)]
pub struct CompileEvent {
    pub dag_nodes: u32,
    pub dag_edges: u32,
    pub compiled_steps: u32,
    pub parallel_tiers: u32,
    pub fused_transforms: u32,
}

// ── Faults (Control Lane, error signals) ────────────────────────────

/// Classification of AI compiler failure modes.
#[derive(Clone, Debug, Serialize, Deserialize)]
pub enum CompileFaultType {
    CycleDetected,
    MissingNode,
    ExecutionFailed,
}

/// Emitted when a compiler operation fails.
#[derive(Clone, Debug, Serialize, Deserialize, VilAiFault)]
pub struct CompileFault {
    pub error_type: CompileFaultType,
    pub message: String,
}

impl CompileFault {
    pub fn cycle_detected(msg: impl Into<String>) -> Self {
        Self {
            error_type: CompileFaultType::CycleDetected,
            message: msg.into(),
        }
    }

    pub fn missing_node(msg: impl Into<String>) -> Self {
        Self {
            error_type: CompileFaultType::MissingNode,
            message: msg.into(),
        }
    }

    pub fn execution_failed(msg: impl Into<String>) -> Self {
        Self {
            error_type: CompileFaultType::ExecutionFailed,
            message: msg.into(),
        }
    }
}

// ── State (Data Lane, mutable tracked) ──────────────────────────────

/// Tracks the current state of the AI compiler.
#[derive(Clone, Debug, Default, Serialize, Deserialize, VilAiState)]
pub struct CompilerState {
    pub total_compilations: u64,
    pub total_executions: u64,
    pub avg_step_count: f32,
    pub avg_tier_count: f32,
}