Struct ToolTask 

pub struct ToolTask { /* private fields */ }

Task that invokes a registered tool from the ToolRegistry.

ToolTask executes external tools (magellan, cargo, splice, etc.) with configurable fallback handlers for error recovery.

Example

use forge_agent::workflow::tasks::ToolTask;
use forge_agent::workflow::tools::ToolInvocation;
use forge_agent::workflow::TaskId;

let task = ToolTask::new(
    TaskId::new("tool_task"),
    "Magellan Query".to_string(),
    "magellan"
)
.args(vec!["find".to_string(), "--name".to_string(), "symbol".to_string()]);

Implementations

impl ToolTask

pub fn new(id: TaskId, name: String, tool_name: impl Into<String>) -> Self

Creates a new ToolTask.

Arguments

• id - Task identifier
• name - Human-readable task name
• tool_name - Name of the registered tool to invoke

Example

use forge_agent::workflow::tasks::ToolTask;
use forge_agent::workflow::TaskId;

let task = ToolTask::new(
    TaskId::new("tool_task"),
    "Query Magellan".to_string(),
    "magellan"
);

pub fn args(self, args: Vec<String>) -> Self

Sets the arguments for the tool invocation.

Arguments

• args - Vector of argument strings

Returns

Self for builder pattern chaining

Example

use forge_agent::workflow::tasks::ToolTask;
use forge_agent::workflow::TaskId;

let task = ToolTask::new(
    TaskId::new("tool_task"),
    "Query Magellan".to_string(),
    "magellan"
)
.args(vec!["find".to_string(), "--name".to_string(), "symbol".to_string()]);

pub fn working_dir(self, dir: impl Into<PathBuf>) -> Self

Sets the working directory for the tool invocation.

Arguments

• dir - Working directory path

Returns

Self for builder pattern chaining

Example

use forge_agent::workflow::tasks::ToolTask;
use forge_agent::workflow::TaskId;

let task = ToolTask::new(
    TaskId::new("tool_task"),
    "Run cargo".to_string(),
    "cargo"
)
.working_dir("/home/user/project");

pub fn env(self, key: impl Into<String>, value: impl Into<String>) -> Self

Adds an environment variable to the tool invocation.

Arguments

• key - Environment variable name
• value - Environment variable value

Returns

Self for builder pattern chaining

Example

use forge_agent::workflow::tasks::ToolTask;
use forge_agent::workflow::TaskId;

let task = ToolTask::new(
    TaskId::new("tool_task"),
    "Run cargo".to_string(),
    "cargo"
)
.env("RUST_LOG", "debug");

pub fn with_fallback(self, handler: Box<dyn FallbackHandler>) -> Self

Sets the fallback handler for error recovery.

Arguments

• handler - Fallback handler to use on tool failure

Returns

Self for builder pattern chaining

Example

use forge_agent::workflow::tasks::ToolTask;
use forge_agent::workflow::tools::RetryFallback;
use forge_agent::workflow::TaskId;

let task = ToolTask::new(
    TaskId::new("tool_task"),
    "Query Magellan".to_string(),
    "magellan"
)
.with_fallback(Box::new(RetryFallback::new(3, 100)));

pub fn tool_name(&self) -> &str

Gets the tool name for this task.

pub fn invocation(&self) -> &ToolInvocation

Gets the invocation for this task.

Trait Implementations

impl WorkflowTask for ToolTask

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, context: &'life1 TaskContext, ) -> Pin<Box<dyn Future<Output = Result<TaskResult, TaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes the task with the provided context.

fn id(&self) -> TaskId

Returns the unique task identifier.

fn name(&self) -> &str

Returns the human-readable task name.

fn compensation(&self) -> Option<CompensationAction>

Returns the compensation action for this task (if any).

fn dependencies(&self) -> Vec<TaskId>

Returns the list of task dependencies.