Struct DynamicWorkflowControl 

pub struct DynamicWorkflowControl { /* private fields */ }

A host-owned control handle for one dynamic workflow run.

The handle keeps the exact source, input, registry, and runtime policy needed to replay the selected run. Mutating operations first acquire the same worker lease used by DynamicWorkflowTool, then ask A3S Flow to append/drive its authoritative events. A live worker therefore remains the sole executor; a controller retries after the redacted lease state reports that the claim is busy.

Implementations

impl DynamicWorkflowControl

pub fn run_id(&self) -> &str

Return the immutable run id bound to this control handle.

pub fn health(&self) -> DynamicWorkflowHealthSnapshot

Return bounded cumulative worker-claim diagnostics shared by this tool and all controls derived from it.

pub async fn diagnostics(&self) -> Result<DynamicWorkflowControlDiagnostics>

Compose workflow claim counters with the optional agent-wide scheduler health snapshot. This is a read-only diagnostic view; Flow history and the worker lease remain the only authorities for workflow state.

pub fn with_allowed_tools( self, allowed_tools: impl IntoIterator<Item = String>, ) -> Self

Replace the set of tools available to replayed script steps.

pub fn with_limits(self, limits: DynamicWorkflowScriptLimits) -> Self

Replace the bounded script and orchestration limits used during replay.

pub fn with_graph_observer(self, observer: FlowGraphObserver) -> Self

Project control-driven Flow events into a graph observer.

pub fn with_task_scheduler( self, scheduler: Arc<TaskScheduler>, admit_steps_globally: bool, ) -> Self

Configure optional global admission for direct script-backed steps.

pub fn with_runtime_build_compatibility( self, compatibility: RuntimeBuildCompatibility, ) -> Self

Set the runtime-build compatibility policy used by control replay.

pub fn with_continuation_lease_ledger( self, ledger: Arc<dyn FlowDecisionLedger>, lease_ms: u64, ) -> Self

Use a caller-owned worker lease ledger for control operations.

pub fn with_continuation_lease_ms(self, lease_ms: u64) -> Self

Change the worker lease while retaining automatic ledger selection.

impl DynamicWorkflowControl

pub async fn inspect(&self) -> Result<DynamicWorkflowControlSnapshot>

Inspect the durable run and return a bounded, digest-only projection.

pub async fn history(&self) -> Result<Vec<FlowEventEnvelope>>

Read the complete durable Flow history for trusted host diagnostics.

Unlike Self::inspect, this method intentionally returns persisted input and step output values. Callers should apply their own redaction policy before exposing the result outside a trusted control plane.

pub async fn request_cancellation( &self, reason: Option<String>, ) -> Result<DynamicWorkflowControlSnapshot>

Request cleanup-aware durable cancellation and settle the worker lease.

A live worker keeps ownership and causes this method to return a busy error; the caller can retry after the lease expires or the worker releases it. This preserves one executor for side-effecting steps.

pub async fn force_cancel( &self, reason: Option<String>, ) -> Result<DynamicWorkflowControlSnapshot>

Immediately terminate the run through Flow’s durable cancellation transition while still fencing the worker claim.

pub async fn drive(&self) -> Result<DynamicWorkflowControlSnapshot>

Resume or start the bound run under the same worker fencing contract as the model-visible dynamic workflow tool.

Trait Implementations

impl Clone for DynamicWorkflowControl

fn clone(&self) -> DynamicWorkflowControl

Returns a duplicate of the value.

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

Performs copy-assignment from source.