Struct AgentTask 

pub struct AgentTask<C: LLMClient> {
    pub id: String,
    pub conversation_id: Uuid,
    pub task_description: String,
    pub context_agent: ContextAgent<C>,
    pub action_agent: ActionAgent<C>,
    pub verifier_agent: VerifierAgent<C>,
    pub state: TaskState,
    pub tool_registry: ToolRegistry,
}

/// Represents a complete agent task composed of three specialized agents:

• ContextAgent: Gathers and analyzes context
• ActionAgent: Takes actions based on context
• VerifierAgent: Verifies actions were successful

Fields

id: String

conversation_id: Uuid

task_description: String

context_agent: ContextAgent<C>

action_agent: ActionAgent<C>

verifier_agent: VerifierAgent<C>

state: TaskState

tool_registry: ToolRegistry

Implementations

impl<C: LLMClient + Send + Sync> AgentTask<C>

pub fn new( id: impl Into<String>, task_description: impl Into<String>, client: C, ) -> Self

where C: Clone,

pub fn add_tool<T: ToolImplementation + 'static>(&self, tool: T)

Add tool to AgentTask ToolRegistry for ActionAgent

pub fn add_tool_arc(&self, tool: Arc<dyn ToolImplementation>)

Add a pre-wrapped tool (Arc<dyn ToolImplementation>) to the registry

pub async fn remove_tool( &mut self, name: &str, ) -> Result<Option<Arc<dyn ToolImplementation>>>

Remove Tool from AgentTask ToolRegistry

pub fn get_all_tools(&self) -> Vec<Tool>

Get all Tools from AgentTask ToolRegistry

pub async fn gather_context(&mut self) -> Result<AgentResponse>

Execute the context gathering phase

pub async fn take_action(&mut self) -> Result<AgentResponse>

Execute the action phase using context from previous phase

pub async fn verify(&mut self) -> Result<AgentResponse>

Execute the verification phase

pub async fn execute_full(&mut self) -> Result<TaskResponse>

Execute the full task pipeline: context -> action -> verify

pub async fn reset(&mut self) -> Result<()>

Reset the task to initial state