Struct WorkflowRun 

pub struct WorkflowRun {

    pub workflow_type: WorkflowType,
    pub prompt: String,
    pub agents: Vec<RunAgent>,
    pub stage_index: usize,
    pub graph: Option<GraphRun>,
    pub generation: u64,
    pub individual_mode: bool,
    pub mode_revision: u64,
    pub status: RunStatus,
    pub completions: BTreeMap<u64, CompletionSignal>,
    pub rounds: BTreeMap<String, u8>,
    pub incoming: BTreeMap<u64, String>,
    pub assignments: BTreeMap<u64, Assignment>,
    pub traces: Vec<WorkflowTrace>,
    pub message: Option<String>,
}

Serializable run state. A run pins both its type reference and definition. Processes and completion mailboxes are deliberately absent; restoring an active run interrupts it.

Fields

workflow_type: WorkflowType

prompt: String

The task. Empty until the first stage reports it when the run starts without one.

agents: Vec<RunAgent>

stage_index: usize

graph: Option<GraphRun>

generation: u64

Changes on every stage entry, including loop backs. UI actions must match this value.

individual_mode: bool

Private follow-ups never start another workflow cycle. Missing in older records.

mode_revision: u64

Invalidates input queued before a mode change without changing stage generations.

status: RunStatus

completions: BTreeMap<u64, CompletionSignal>

rounds: BTreeMap<String, u8>

incoming: BTreeMap<u64, String>

assignments: BTreeMap<u64, Assignment>

Assignment ownership remains in force when a review loop revisits a worker.

traces: Vec<WorkflowTrace>

message: Option<String>

Implementations

impl WorkflowRun

pub fn stage_name(&self) -> &str

pub fn stage_id(&self) -> &str

pub fn assignment_generation(&self, agent_id: u64) -> u64

impl WorkflowRun

pub fn reference(&self) -> WorkflowTypeRef

pub fn active_agents(&self) -> Vec<&RunAgent>

pub fn is_reviewer(&self, agent_id: u64) -> bool

pub fn assignment_targets(&self, agent_id: u64) -> Vec<&RunAgent>

Receivers whose assignments must be supplied by this participant before it can finish.

pub fn needs_task(&self) -> bool

Whether the run started without a task and nobody has reported it yet.

Trait Implementations

impl Clone for WorkflowRun

fn clone(&self) -> WorkflowRun

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowRun

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkflowRun

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for WorkflowRun

impl PartialEq for WorkflowRun

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for WorkflowRun

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for WorkflowRun