Skip to main content

run_scheduled_claim_renewal_loop

Function run_scheduled_claim_renewal_loop 

Source
pub async fn run_scheduled_claim_renewal_loop<Store>(
    store: Store,
    claim: ScheduledTaskClaim,
    claim_ttl: Duration,
    interval: Duration,
    stop_token: CancellationToken,
)
where Store: ScheduledTaskStore,
Expand description

Renews one owned scheduled task claim until stopped or the claim is lost.

Mirrors the background task heartbeat loop: Ok(false) means the ownership predicate no longer matches (another runtime reclaimed the firing), so the loop stops; Err(_) is logged and retried on the next tick. The loop never aborts the running task body — completion still guards on ownership.