Struct TaskAgent 

pub struct TaskAgent {
    pub id: String,
    /* private fields */
}

Autonomous task agent that runs a provider + tool loop until completion.

Create with TaskAgent::new, then call TaskAgent::execute (or spawn it on a background task with spawn_task_agent).

Fields

id: String

Unique agent ID.

Implementations

impl TaskAgent

pub fn new( id: String, task: Task, provider: Arc<dyn Provider>, context: Arc<AgentContext>, config: TaskAgentConfig, ) -> Self

Create a new task agent.

The agent starts in TaskAgentStatus::Idle and does not begin execution until execute is called.

pub fn id(&self) -> &str

Get the agent’s unique ID.

pub async fn status(&self) -> TaskAgentStatus

Get the current status.

pub async fn task(&self) -> Task

Get a snapshot of the task.

pub async fn conversation_snapshot(&self) -> Vec<Message>

Get a read-only snapshot of the conversation history.

pub async fn conversation_len(&self) -> usize

Get the current message count.

pub async fn inject_message(&self, msg: Message)

Inject a message into the conversation (e.g., from a parent agent).

pub async fn execute(&self) -> Result<TaskAgentResult>

Execute the task to completion, returning the result.

Blocks the calling async task until the agent finishes. Use spawn_task_agent to run the agent on a Tokio background task.