Struct DynamicWorkflowRuntime 

pub struct DynamicWorkflowRuntime { /* private fields */ }

Runs A3S Flow workflow and step invocations through a sandboxed PTC script.

Implementations

impl DynamicWorkflowRuntime

pub fn new( registry: Arc<ToolRegistry>, context: ToolContext, source: impl Into<String>, ) -> Self

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

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

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

Attach the agent-wide scheduler when this runtime is used as a standalone host adapter.

admit_steps_globally = false is the correct setting for a runtime invoked from an existing AgentSession operation: the parent operation already owns the global lease and Flow steps use the local bounded gate.

pub fn with_task_scheduler_quota(self, quota: TaskSchedulerQuota) -> Self

Bind a digest-only owner quota to scheduler-backed Flow admissions.

This does not create another queue or workflow authority; it only tells the existing scheduler how many slots this runtime may own at once.

pub fn admission_stats(&self) -> DynamicWorkflowAdmissionStats

Return local Flow-step admission counters for diagnostics and hosts.

pub async fn scheduler_quota_snapshot( &self, ) -> Result<Option<TaskSchedulerQuotaSnapshot>, TaskSchedulerError>

Return the live owner-quota projection for this runtime, when it is layered on an agent-wide scheduler. The projection contains only the digest identity and current occupancy; Flow history and worker leases remain independent authorities.

Trait Implementations

impl Clone for DynamicWorkflowRuntime

fn clone(&self) -> DynamicWorkflowRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl FlowRuntime for DynamicWorkflowRuntime

fn run_workflow<'life0, 'async_trait>( &'life0 self, invocation: WorkflowInvocation, ) -> Pin<Box<dyn Future<Output = Result<RuntimeCommand>> + Send + 'async_trait>>

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

Replay the deterministic workflow function and return the next command.

fn run_step<'life0, 'async_trait>( &'life0 self, invocation: StepInvocation, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

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

Execute one side-effecting step. The engine persists success/failure.