Struct Task 

pub struct Task {

    pub schema: u32,
    pub id: String,
    pub title: String,
    pub instruction: String,
    pub repo: PathBuf,
    pub source: Source,
    pub priority: i32,
    pub solo: bool,
    pub status: TaskStatus,
    pub attempts: usize,
    pub runs: Vec<String>,
    pub last_error: Option<String>,
    pub created_at: Timestamp,
    pub updated_at: Timestamp,
}

One unit of work.

Fields

schema: u32

On-disk format version.

id: String

Task id, e.g. 20260902-140501-a1b2.

title: String

One line, for lists and notifications.

instruction: String

The task itself, handed to the graph verbatim.

repo: PathBuf

Repository to work in.

source: Source

Who asked.

priority: i32

Higher runs first; ties break oldest-first so nothing starves.

solo: bool

Run this task alone: one implementer, no panel of judges to convince.

#[serde(default)] so a queue file written before this field existed still reads, as false - the ordinary multi-candidate competition, unchanged. A task set to solo still runs the whole graph; only the candidate count the daemon builds it with changes, and crate::graph::Runner already collapses a single-candidate run to implement → review → gate → merge on its own (see crate::graph::Runner::review’s doc), so nothing about judging, deliberation or voting had to change to support this.

status: TaskStatus

Current state.

attempts: usize

How many times this task has been claimed.

runs: Vec<String>

Runs this task has produced, oldest first.

last_error: Option<String>

Why the last attempt did not land.

created_at: Timestamp

When the task was filed.

updated_at: Timestamp

Last change to this file.

Implementations

impl Task

pub fn new( title: String, instruction: String, repo: PathBuf, source: Source, ) -> Self

File a new task. Persist it with Queue::put.

pub fn short(&self) -> &str

Short form used in reports, matching a run’s short id.

pub fn start(&mut self, run: String)

Record that a run has started for this task.

pub fn succeed(&mut self)

Record a successful run.

pub fn fail(&mut self, why: impl Into<String>, max_attempts: usize)

Record a failed attempt. Out of attempts means held for a human, rather than retried until the money runs out.

pub fn stall(&mut self, why: impl Into<String>)

Record an attempt that failed for a reason the task is not responsible for - the agent CLIs ran out of quota and the judging panel collapsed.

This refunds the attempt on purpose. A quota window closing at 4am must not spend the backlog’s retry budget: the operator would come back to a queue of held tasks that were never actually judged, and would have to release every one by hand to find out which had a real problem. The task goes back to Failed, which the loop retries, so a reset quota picks the work up where it stopped.

pub fn hold(&mut self)

Take this task out of the loop’s reach without deleting it.

pub fn handed_off(&mut self, why: impl Into<String>)

Record a run that produced a pull request without merging it.

The task is held rather than retried, and it costs no further attempt either way. The work the task asked for exists: it is sitting on a branch, in a pull request, waiting for CI or for a person. Retrying would spend the whole competition budget a second time and then race a second branch against the pull request the first one opened - which is exactly what happened to run 01c2, whose finished and green pull request was re-competed from scratch four seconds after it opened.

A pull request nobody merged is a request for a person, not a failure.

pub fn release(&mut self)

Put a held or finished task back in line, with its attempt count reset so a release is a real second chance rather than an instant re-hold. The run history is kept: attempts reset, evidence does not.

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Task

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Task

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Task

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

where __S: Serializer,

Serialize this value into the given Serde serializer.