desktop/src-tauri/crates/core/src/jobs.rs

Comment 1, line 1

//! Collection jobs: ingest_runs states running/interrupted/succeeded/failed/cancelled.

//! One running job per source; overlapping triggers merge into it. Scheduling/concurrency

//! integrate through M6; this module stores jobs. Storage::open marks running as interrupted.

/// A new job.

/// Merge the trigger into the existing running source job and return its ID.

/// Start collection, or merge trigger reasons and return Merged for a running source.

/// End running as succeeded/failed/cancelled/interrupted; other transitions are invalid.

/// Update counts in the same batch transaction as events, cursors and aggregates.

/// Fallback timestamp when a monotonic clock is unavailable during open/migration.