Struct TaskExecutor 

pub struct TaskExecutor { /* private fields */ }

Task executor with cached providers, shared HTTP client, and event logging

Implementations

impl TaskExecutor

pub async fn expand_decompose( &self, spec: &DecomposeSpec, bindings: &ResolvedBindings, datastore: &RunContext, ) -> Result<Vec<Value>, NikaError>

Expand a decompose spec into iteration items

Returns an array of JSON values that can be used as for_each items. Supports semantic (MCP traverse), static (binding resolution), and nested strategies.

impl TaskExecutor

pub fn new( provider: &str, model: Option<&str>, mcp_configs: Option<FxHashMap<String, McpConfigInline>>, event_log: EventLog, ) -> Result<Self, NikaError>

Create a new executor with default provider, model, MCP configs, and event log

pub fn with_policy( provider: &str, model: Option<&str>, mcp_configs: Option<FxHashMap<String, McpConfigInline>>, event_log: EventLog, policy_config: Option<PolicyConfig>, permission_mode: Option<PermissionMode>, ) -> Result<Self, NikaError>

Create a new executor with explicit policy configuration.

Returns an error if the media compute pool cannot be created.

pub fn set_permission_mode(&self, mode: PermissionMode)

Set the permission mode for file tools (nika:write, nika:edit, etc.)

pub fn with_cancel_token(self, token: CancellationToken) -> Self

Set a cancellation token for aborting in-flight operations.

When the token is cancelled, MCP invoke operations will abort promptly instead of waiting for the full INVOKE_TASK_DEADLINE timeout.

pub fn is_cancelled(&self) -> bool

Check if the executor has been cancelled.

pub fn with_skills( self, skills_map: HashMap<String, String>, base_dir: PathBuf, ) -> Self

Set the workflow-level skills mapping for agent skill injection.

When set, agents with skills: configured will have skill content loaded and prepended to their system prompts via SkillInjector.

pub async fn execute( &self, task_id: &Arc<str>, action: &TaskAction, bindings: &ResolvedBindings, datastore: &RunContext, output_policy: Option<&OutputPolicy>, ) -> Result<String, NikaError>

Run a task action with the given bindings

The datastore is required for resolving lazy bindings during template substitution. The output_policy is used to inject JSON schema instructions into prompts for infer/agent.

pub fn default_provider(&self) -> &str

Get the default provider name.

pub async fn shutdown_mcp(&self)

Gracefully shut down all MCP server connections.

Delegates to McpClientPool::shutdown_all which terminates server processes and marks the pool as shut down. Idempotent.

Trait Implementations

impl Clone for TaskExecutor

fn clone(&self) -> TaskExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.