Struct DurableProcessWorker 

pub struct DurableProcessWorker { /* private fields */ }

Reconstructable background-process worker.

Implementations

impl DurableProcessWorker

pub fn new(config: DurableProcessWorkerConfig) -> Self

pub fn from_shared_config(config: Arc<DurableProcessWorkerConfig>) -> Self

pub fn config(&self) -> &DurableProcessWorkerConfig

pub async fn run_process( &self, registration: ProcessRegistration, execution_context: ProcessExecutionContext, cancellation: CancellationToken, ) -> Result<ProcessAwaitOutput, PluginError>

pub async fn run_process_with_scoped_effect_controller( &self, registration: ProcessRegistration, execution_context: ProcessExecutionContext, scoped_effect_controller: ScopedEffectController<'_>, cancellation: CancellationToken, ) -> Result<ProcessAwaitOutput, PluginError>

pub async fn drive_pending_processes(&self) -> Result<(), PluginError>

Sweep the registry for non-terminal processes and re-execute the ones this worker can claim, driving each to a terminal state.

This is the crash-recovery counterpart to a worker that ran a process from a live turn: a trigger/host-event-started process whose worker died mid-flight is left non-terminal in the registry, and a subsequent worker reopening that registry must finish it. The sweep:

1. lists every non-terminal process (ProcessRegistry::list_non_terminal);
2. claims the durable single-owner ProcessLease over each — a process already leased live by another owner is skipped (it is being run by that owner right now), so a non-terminal process is re-run by exactly one owner (lease fencing);
3. runs the claimed process on this worker’s wired controller, renewing the lease across the long-running execution so a healthy recovery is not swept out from under itself;
4. writes the terminal outcome and releases the lease.

Idempotent by process_id: terminal processes are never in the worklist, and a process that became terminal between the list and the claim is detected after claiming and skipped, so re-running a recovery sweep does not double-execute completed work.

pub async fn request_process_cancel( &self, process_id: &str, reason: Option<String>, ) -> Result<(), PluginError>

Trait Implementations

impl Clone for DurableProcessWorker

fn clone(&self) -> DurableProcessWorker

Returns a duplicate of the value.

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

Performs copy-assignment from source.