Module dispatch 

Activity completion handling and dispatch abstractions. Push dispatch for remote activity workers and result handoff to the engine contract.

Structs

ActivityCompletion

Correlated activity completion handed to the engine-owned activity contract.

ActivityDispatcher

Push dispatcher backed by the connected-worker registry.

ScheduledActivity

Scheduled remote activity that must be placed with a connected worker.

Enums

ActivityCompletionOutcome

Decoded activity outcome reported by a worker.

Traits

ActivityCompletionSink

Engine-owned activity completion contract used by the worker endpoint.

Functions

handle_activity_result

Decode and hand a worker result to the engine-owned activity completion sink.

lost_worker_error

Build the retryable failure reported when a worker loses ownership of an in-flight task.