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