Enum StaleRunPolicy 

pub enum StaleRunPolicy {
    LostOnDisappear,
    AdoptLiveHosts {
        origins: Vec<String>,
    },
}

What a freshly-constructed TaskDriver does with Running rows it finds already in the store.

The historical rule — tombstone every one of them — bakes in an assumption that stops being true the moment a second process attaches to the same store: that any Running row must be a corpse from this process’s predecessor. When two processes share a store, a driver starting up in one will happily mark the other’s live runs Lost, and the run keeps producing output under a status that says it is dead.

The policy is deliberately origin-agnostic in its mechanism — it decides on who owns the run (TaskRunMeta::host_pid) — and takes the origin list as data, so an embedder names the runs it wants exempted without this crate knowing what any of them mean.

Variants

LostOnDisappear

Tombstone every leftover Running run as Lost.

Correct, and the default, whenever this process is the only writer: a run whose driver is gone has no one left to notice it exit.

AdoptLiveHosts

Spare runs whose recorded owner process is still alive.

A leftover run is tombstoned only when its host_pid is absent (owner unknown — a row from before the column existed) or names a process that no longer exists. Anything else belongs to a live peer and is left Running for that peer to finish.

origins narrows the exemption to runs whose TaskRunMeta::origin is in the list; empty means every origin qualifies. A run with no origin never matches a non-empty list.

Fields

origins: Vec<String>

Trait Implementations

impl Clone for StaleRunPolicy

fn clone(&self) -> StaleRunPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StaleRunPolicy

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

Formats the value using the given formatter.

impl Default for StaleRunPolicy

fn default() -> StaleRunPolicy

Returns the “default value” for a type.

impl Eq for StaleRunPolicy

impl PartialEq for StaleRunPolicy

fn eq(&self, other: &StaleRunPolicy) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for StaleRunPolicy