Function load_streaming_jobs_by_ids 

pub(crate) async fn load_streaming_jobs_by_ids<C>(
    txn: &C,
    job_ids: impl IntoIterator<Item = JobId>,
) -> MetaResult<HashMap<JobId, Model>>
where
    C: ConnectionTrait,

Load streaming jobs by job ids.