Struct Executor 

pub struct Executor { /* private fields */ }

Executor configuration for a durable worker.

Implementations

impl Executor

pub fn new(db: DatabaseConnection, executor_id: String) -> Self

pub fn db(&self) -> &DatabaseConnection

pub fn executor_id(&self) -> &str

pub async fn heartbeat(&self) -> Result<(), DurableError>

Write (or upsert) a heartbeat row for this executor.

pub fn start_heartbeat(&self, config: &HeartbeatConfig) -> JoinHandle<()>

Spawn a background tokio task that calls heartbeat() every config.heartbeat_interval.

Returns a JoinHandle so the caller can abort it on graceful shutdown.

pub async fn recover_stale_tasks( &self, staleness_threshold: Duration, ) -> Result<Vec<RecoveredTask>, DurableError>

Reset RUNNING tasks from dead workers to PENDING. Catches three cases:

1. Tasks whose executor_id has a stale heartbeat (> staleness_threshold)
2. Tasks whose executor_id has no heartbeat row at all (executor never registered or was cleaned up)
3. Orphaned tasks with NULL executor_id that have been RUNNING too long

Excludes own executor_id — own tasks are handled by the current process. Returns the recovered tasks.

pub async fn recover(&self) -> Result<Vec<RecoveredTask>, DurableError>

Scan for stale tasks by timeout and reset them to PENDING.

A task is considered stale if:

• status = 'RUNNING'
• timeout_ms IS NOT NULL or deadline_epoch_ms IS NOT NULL
• started_at IS NOT NULL
• The timeout/deadline has elapsed

Tasks without timeout_ms set are never considered stale.