Struct ShellCommandTask 

pub struct ShellCommandTask { /* private fields */ }

Task that executes shell commands using tokio::process.

Executes external shell commands with configurable working directory, environment variables, and timeout settings. Supports process compensation for rollback operations.

Implementations

impl ShellCommandTask

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

Creates a new ShellCommandTask with the given command.

Arguments

• id - Task identifier
• name - Human-readable task name
• command - Command to execute (e.g., “echo”, “ls”, “cargo”)

pub fn with_config(id: TaskId, name: String, config: ShellCommandConfig) -> Self

Creates a new ShellCommandTask with a ShellCommandConfig.

Arguments

• id - Task identifier
• name - Human-readable task name
• config - Shell command configuration

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

👎Deprecated since 0.4.0: Use with_config() instead for better configurability

Sets the arguments for the shell command.

Deprecated

Use with_config() and ShellCommandConfig::args() instead.

pub fn command(&self) -> &str

Gets the command for this task.

pub fn args(&self) -> &[String]

Gets the arguments for this task.

pub fn config(&self) -> &ShellCommandConfig

Gets the configuration for this task.

Trait Implementations

impl WorkflowTask for ShellCommandTask

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.