Struct Job 

pub struct Job {
    pub id: JobId,
    pub deps: Vec<JobId>,
    pub prompt: String,
    pub retry: RetryPolicy,
    pub state: JobState,
    pub result: Option<JobResult>,
    pub attempts: u32,
    pub visits: u32,
    pub last_error: Option<String>,
    pub prior_attempt: Option<String>,
    pub feedback: Option<String>,
}

One node in the Run DAG.

Fields

id: JobId

deps: Vec<JobId>

Ids of Jobs that must Succeed before this one can run.

prompt: String

The task description handed to the runner (e.g. a sub-agent prompt).

retry: RetryPolicy

state: JobState

result: Option<JobResult>

attempts: u32

How many times this Job has been run so far.

visits: u32

How many times this Job has been entered — one per run, plus one for every time a Next::Goto sent the graph back through it. Distinct from attempts, which counts retries of a single entry: a job that fails twice and is revisited once has 2 attempts and 2 visits, and only the second bounds the loop.

last_error: Option<String>

Error from the most recent failed attempt, if any.

prior_attempt: Option<String>

What this job produced on the previous lap, and why it was sent back. Set only by a Next::Goto; the runner puts both in front of the job so it can improve on its own answer instead of reproducing it.

feedback: Option<String>

Implementations

impl Job

pub fn new(id: impl Into<JobId>, prompt: impl Into<String>) -> Self

pub fn with_deps<I, S>(self, deps: I) -> Self

where I: IntoIterator<Item = S>, S: Into<JobId>,

pub fn with_retry(self, retry: RetryPolicy) -> Self

Trait Implementations

impl Clone for Job

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Job

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Job

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Job

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

where __S: Serializer,

Serialize this value into the given Serde serializer.