Struct MlJob 

pub struct MlJob {
    pub id: u128,
    pub kind: MlJobKind,
    pub target_name: String,
    pub status: MlJobStatus,
    pub progress: u8,
    pub created_at_ms: u64,
    pub started_at_ms: u64,
    pub finished_at_ms: u64,
    pub error_message: Option<String>,
    pub spec_json: String,
    pub metrics_json: Option<String>,
}

Persistent state of a single ML job.

Everything the operator needs to inspect SELECT * FROM ML_JOBS lives here. spec_json carries kind-specific parameters (which algorithm, which features, which hyperparameters); workers parse it themselves so the registry stays schema-free.

Fields

id: u128

kind: MlJobKind

target_name: String

Name of the model / feature / embedding column the job mutates.

status: MlJobStatus

progress: u8

0..=100.

created_at_ms: u64

Epoch millis. 0 when not yet scheduled / finished.

started_at_ms: u64

finished_at_ms: u64

error_message: Option<String>

Populated on Failed.

spec_json: String

Free-form payload describing the job — parsed by the worker.

metrics_json: Option<String>

Free-form metrics (accuracy, f1, etc.) — written by the worker before it transitions to Completed.

Implementations

impl MlJob

pub fn new( id: u128, kind: MlJobKind, target_name: String, spec_json: String, ) -> MlJob

pub fn is_terminal(&self) -> bool

True once the job has reached a terminal status.

pub fn duration_ms(&self) -> Option<u64>

Duration between started_at and finished_at, if both are set. None while the job is still running or never started.

impl MlJob

pub fn to_json(&self) -> String

Encode as a compact JSON object suitable for KV storage.

pub fn from_json(raw: &str) -> Option<MlJob>

Inverse of Self::to_json. Returns None on any field mismatch — callers either skip the record or surface a persistence-corruption error.

Trait Implementations

impl Clone for MlJob

fn clone(&self) -> MlJob

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MlJob

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

Formats the value using the given formatter.