entrenar 0.7.10

Training & Optimization library with autograd, LoRA, quantization, and model merging
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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130

//! Monitoring Configuration
//!
//! Contains monitoring and tracking configuration types for training manifests.

use serde::{Deserialize, Serialize};
use std::collections::HashMap;

/// Monitoring configuration (genchi genbutsu - go and see)
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct MonitoringConfig {
    /// Terminal visualization
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub terminal: Option<TerminalMonitor>,

    /// Experiment tracking
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub tracking: Option<TrackingConfig>,

    /// System metrics
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub system: Option<SystemMonitorConfig>,

    /// Alerts (Andon system)
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub alerts: Option<Vec<AlertConfig>>,

    /// Drift detection configuration
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub drift_detection: Option<DriftDetectionConfig>,
}

/// Drift detection configuration
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct DriftDetectionConfig {
    /// Whether drift detection is enabled
    pub enabled: bool,

    /// Path to baseline statistics
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub baseline: Option<String>,

    /// Threshold for triggering drift alert (e.g., PSI threshold)
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub threshold: Option<f64>,

    /// Window size for drift detection
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub window: Option<usize>,

    /// Features to monitor for drift
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub features: Option<Vec<String>>,

    /// Drift detection method (e.g., "psi", "ks", "wasserstein")
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub method: Option<String>,
}

/// Terminal monitoring configuration
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct TerminalMonitor {
    /// Enable terminal monitoring
    pub enabled: bool,

    /// Refresh rate in ms
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub refresh_rate: Option<usize>,

    /// Metrics to display
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub metrics: Option<Vec<String>>,

    /// Charts configuration
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub charts: Option<Vec<ChartConfig>>,
}

/// Chart configuration
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ChartConfig {
    #[serde(rename = "type")]
    pub chart_type: String,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub metric: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub window: Option<usize>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub show_eta: Option<bool>,
}

/// Experiment tracking configuration
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct TrackingConfig {
    /// Enable tracking
    pub enabled: bool,

    /// Backend (trueno-db, mlflow, wandb, tensorboard)
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub backend: Option<String>,

    /// Project name
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub project: Option<String>,

    /// Experiment name (supports templates)
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub experiment: Option<String>,

    /// Tags
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub tags: Option<HashMap<String, String>>,
}

/// System monitoring configuration
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct SystemMonitorConfig {
    pub enabled: bool,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub interval: Option<usize>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub metrics: Option<Vec<String>>,
}

/// Alert configuration (Andon system)
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct AlertConfig {
    pub condition: String,
    pub action: String,
    pub message: String,
}