pub(crate) async fn assign_cdc_table_snapshot_splits_pairs(
table_id_actor_ids: impl IntoIterator<Item = (u32, HashSet<u32>)>,
meta_store: &SqlMetaStore,
completed_cdc_job_ids: HashSet<u32>,
) -> MetaResult<CdcTableSnapshotSplitAssignment>