pub async fn get_streaming_job_extra_info<C>(
txn: &C,
job_ids: Vec<JobId>,
) -> MetaResult<HashMap<JobId, StreamingJobExtraInfo>>where
C: ConnectionTrait,pub async fn get_streaming_job_extra_info<C>(
txn: &C,
job_ids: Vec<JobId>,
) -> MetaResult<HashMap<JobId, StreamingJobExtraInfo>>where
C: ConnectionTrait,