Struct WorkflowExecutionRequest 

pub struct WorkflowExecutionRequest {
    pub run_id: RunId,
    pub workflow_id: WorkflowId,
    pub plan: Plan,
    pub run_grant: RunToolGrant,
    pub working_set: WorkingSet,
    pub cancellation: CancellationToken,
    pub progress_reporter: Option<Arc<dyn ExecutionProgressReporter>>,
    pub max_tool_calls: Option<u64>,
    pub recovery_replay: bool,
}

One invocation of the workflow execution strategy.

Fields

run_id: RunId

workflow_id: WorkflowId

plan: Plan

run_grant: RunToolGrant

working_set: WorkingSet

cancellation: CancellationToken

progress_reporter: Option<Arc<dyn ExecutionProgressReporter>>

Bridge into the owning Agent Run’s live progress stream.

max_tool_calls: Option<u64>

Optional Run-specific cap. The strategy’s Host cap still wins.

recovery_replay: bool

Re-enter an already fenced Workflow using only durable Tool outcomes. The strategy performs a global unresolved-effect preflight before any new Step is dispatched.

Implementations

impl WorkflowExecutionRequest

pub fn new( run_id: RunId, workflow_id: WorkflowId, plan: Plan, run_grant: RunToolGrant, ) -> Self

pub fn with_working_set(self, working_set: WorkingSet) -> Self

pub fn with_cancellation(self, cancellation: CancellationToken) -> Self

pub fn with_progress_reporter( self, progress_reporter: Arc<dyn ExecutionProgressReporter>, ) -> Self

pub fn with_max_tool_calls(self, max_tool_calls: u64) -> Self

pub fn with_recovery_replay(self) -> Self