async fn fetch_serving_infos(
metadata_manager: &MetadataManager,
) -> (Vec<WorkerNode>, HashMap<FragmentId, FragmentParallelismInfo>)
async fn fetch_serving_infos(
metadata_manager: &MetadataManager,
) -> (Vec<WorkerNode>, HashMap<FragmentId, FragmentParallelismInfo>)