async fn resolve_source_fragments<C>(
txn: &C,
job_fragments: &HashMap<JobId, HashMap<FragmentId, LoadedFragment>>,
) -> MetaResult<(HashMap<FragmentId, SourceId>, HashMap<FragmentId, Vec<SplitImpl>>)>where
C: ConnectionTrait,async fn resolve_source_fragments<C>(
txn: &C,
job_fragments: &HashMap<JobId, HashMap<FragmentId, LoadedFragment>>,
) -> MetaResult<(HashMap<FragmentId, SourceId>, HashMap<FragmentId, Vec<SplitImpl>>)>where
C: ConnectionTrait,