Skip to main content

claim_worker_rows

Function claim_worker_rows 

Source
fn claim_worker_rows(
    adapter: &dyn DatabaseOperations,
    config: &DbBackendConfig,
    schema: &AppSchema,
    snapshot: &mut Value,
    epoch: i64,
) -> Result<(), DatabaseError>
Expand description

Acquires adapter-owned leases before any delivery side effect. The transient view retains the due status expected by the existing processors, while completion guards compare the committed lease to prevent stale acknowledgments.