Struct Run 

pub struct Run<S: ExperimentStorage> {
    pub id: String,
    pub experiment_id: String,
    /* private fields */
}

A training run with integrated distributed tracing

Generic over the storage backend, allowing different backends for production (TruenoBackend) and testing (InMemoryStorage).

Fields

id: String

Run ID

experiment_id: String

Parent experiment ID

Implementations

impl<S: ExperimentStorage> Run<S>

pub fn metric_keys(&self) -> Vec<String>

Get all metric keys that have been logged.

impl<S: ExperimentStorage> Run<S>

pub fn new( experiment_id: &str, storage: Arc<Mutex<S>>, config: TracingConfig, ) -> Result<Self>

Create a new run with tracing

Creates a run in the storage backend, starts it, and optionally creates a Renacer span for distributed tracing.

Arguments

• experiment_id - ID of the parent experiment
• storage - Shared storage backend
• config - Tracing configuration

pub fn log_metric(&mut self, key: &str, value: f64) -> Result<()>

Log a metric value, auto-incrementing the step

Each metric key has its own step counter that starts at 0 and increments with each call.

Arguments

• key - Metric name (e.g., “loss”, “accuracy”)
• value - Metric value

pub fn log_metric_at(&mut self, key: &str, step: u64, value: f64) -> Result<()>

Log a metric value at a specific step

Arguments

• key - Metric name
• step - Training step
• value - Metric value

pub fn finish(self, status: RunStatus) -> Result<()>

Finish the run with the given status

Completes the run in storage and ends the Renacer span. Consumes the Run to prevent further operations.

Arguments

• status - Final run status

pub fn span_id(&self) -> Option<&str>

Get the Renacer span ID (if tracing is enabled)

pub fn run_id(&self) -> &str

Get the run ID

pub fn tracing_config(&self) -> &TracingConfig

Get the tracing configuration

pub fn is_finished(&self) -> bool

Check if the run has been finished

pub fn current_step(&self, key: &str) -> u64

Get current step for a metric key

Trait Implementations

impl<S: ExperimentStorage> DashboardSource for Run<S>

fn status(&self) -> RunStatus

Get the current run status.

fn recent_metrics(&self, limit: usize) -> HashMap<String, MetricSnapshot>

Get recent metrics, limited to limit points per metric.

fn subscribe(&self, _callback: SubscriptionCallback)

Subscribe to metric updates.

fn resource_usage(&self) -> ResourceSnapshot

Get current resource usage.

impl<S: ExperimentStorage> Debug for Run<S>

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

Formats the value using the given formatter.