Struct InlineProcessRunHandle 

pub struct InlineProcessRunHandle { /* private fields */ }

Inline run handle: drives the worker’s own lease-protected sweep in-process.

Delegates to DurableProcessWorker::drive_pending_processes, the existing list_non_terminal -> claim lease -> run -> complete -> release loop, so the inline tier reuses the same coordination point as the durable tier.

Implementations

impl InlineProcessRunHandle

pub fn new(worker: DurableProcessWorker) -> Self

Trait Implementations

impl ProcessRunHandle for InlineProcessRunHandle

fn claim_and_run_pending<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>

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

Claim and run every pending process this owner can claim, driving each to a terminal state. Idempotent: leased and terminal rows are skipped.