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<u64, DurableError>

Reset RUNNING tasks from dead workers (stale heartbeat > staleness_threshold) to PENDING.

Excludes own executor_id — own tasks are handled by startup reset. Returns the number of rows affected.

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

Spawn a background tokio task that calls recover_stale_tasks() every config.staleness_threshold interval.

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.