pub async fn claim_due_for_lane<Store, Task, Kind, Lane, LaneFn>(
store: &Store,
lane_config: TaskLaneConfig<Kind, Lane>,
processing_stale_secs: i64,
task_lane: LaneFn,
) -> Result<Vec<(Task, TaskLease)>, Store::Error>Expand description
Claims due tasks for a single lane using a product storage adapter.