Function run_claimed_task_batch_with_store 

pub async fn run_claimed_task_batch_with_store<Store, Task, Kind, SortKey, SortFn, LeaseExpiresFn, RetryDelayFn>(
    store: Store,
    claimed_tasks: Vec<(Task, TaskLease)>,
    sort_key: SortFn,
    shutdown_token: CancellationToken,
    config: ClaimedTaskExecutionConfig<LeaseExpiresFn, RetryDelayFn>,
) -> Result<DispatchStats, Store::Error>
where
    Store: ClaimedTaskExecutionStore<Task, Kind> + 'static,
    Task: ExecutableTaskRecord<Kind> + Clone + Send + Sync + 'static,
    Kind: Copy + Display + Send + Sync + 'static,
    SortKey: Ord,
    SortFn: FnMut(&(Task, TaskLease)) -> SortKey,
    LeaseExpiresFn: Fn(DateTime<Utc>) -> DateTime<Utc> + Copy + Send + Sync + 'static,
    RetryDelayFn: Fn(i32) -> i64 + Copy + Send + Sync + 'static,

Runs a claimed task batch using the shared lifecycle and aggregates counters.