Struct WorkflowVm 

pub struct WorkflowVm { /* private fields */ }

Executes Workflow scripts, one isolated QuickJS runtime per run.

Every WorkflowVm::run_script call spins up a fresh interpreter on a dedicated thread, so runs share nothing (globals, heap, interned atoms) and a wedged script can never stall a sibling run.

Implementations

impl WorkflowVm

pub fn new() -> Self

A VM with the default VmLimits.

pub fn with_limits(limits: VmLimits) -> Self

A VM with explicit resource limits.

pub async fn run_script( &self, source: &str, args: Value, driver: Arc<dyn WorkflowDriver>, ) -> Result<Value, WorkflowJsError>

Run one Workflow script to completion.

• source is the script body; it is wrapped in an async function, so top-level await and return both work. The returned value is the script’s return value, JSON-encoded (undefined becomes null).
• args is exposed verbatim to the script as the args global.
• driver executes task() spawns and receives progress events. A driver instance is scoped to exactly one run: cancel_all is always invoked at run teardown (success, script error, or cancellation), so stray children never outlive the script that spawned them.

Cancellation cascade (design §9): dropping the returned future cancels the run — the interrupt handler aborts executing JS, pending task() awaits resolve to errors, and driver.cancel_all() is invoked immediately from the dropping thread.

Trait Implementations

impl Clone for WorkflowVm

fn clone(&self) -> WorkflowVm

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkflowVm

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WorkflowVm

fn default() -> WorkflowVm

Returns the “default value” for a type.