Struct Task 

pub struct Task {
    pub id: TaskId,
    pub intent: Intent,
    pub plan: Option<Plan>,
    pub state: TaskState,
    pub completed_step_ids: Vec<StepId>,
    pub working_set_snapshot: HashMap<String, Value>,
    pub created_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
}

Task - the stateful execution context

Fields

id: TaskId

Unique identifier for this task

intent: Intent

The intent that initiated this task

plan: Option<Plan>

The execution plan (if planning is complete)

state: TaskState

Current state of the task

completed_step_ids: Vec<StepId>

Completed step IDs for resume/replay

working_set_snapshot: HashMap<String, Value>

Task-scope working set snapshot for resume

created_at: DateTime<Utc>

Creation timestamp

updated_at: DateTime<Utc>

Last update timestamp

Implementations

impl Task

pub fn new(intent: Intent) -> Task

Create a new task from an intent

pub fn set_state(&mut self, state: TaskState)

Update the task state

pub fn set_plan(&mut self, plan: Plan)

Set the plan

pub fn start_executing(&mut self)

Transition to executing state

pub fn wait_for_user(&mut self, prompt: impl Into<String>)

Transition to waiting for user

pub fn wait_for_approval(&mut self, request: &ApprovalRequest)

pub fn fail(&mut self, reason: impl Into<String>, recoverable: bool)

Transition to failed state

pub fn complete(&mut self)

Transition to done state

pub fn pause(&mut self)

Pause the task

pub fn set_checkpoint( &mut self, completed_step_ids: Vec<StepId>, working_set_snapshot: HashMap<String, Value>, )

Update execution checkpoint data

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<(), Error>

Formats the value using the given formatter.

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

fn deserialize<__D>( __deserializer: __D, ) -> Result<Task, <__D as Deserializer<'de>>::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 as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.