async fn build_reschedule_intent_for_jobs(
txn: &impl ConnectionTrait,
job_ids: HashSet<JobId>,
) -> MetaResult<HashMap<DatabaseId, Command>>async fn build_reschedule_intent_for_jobs(
txn: &impl ConnectionTrait,
job_ids: HashSet<JobId>,
) -> MetaResult<HashMap<DatabaseId, Command>>