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.