Function assign_cdc_table_snapshot_splits 

pub(crate) async fn assign_cdc_table_snapshot_splits(
    original_table_job_id: JobId,
    job: &StreamJobFragments,
    meta_store: &SqlMetaStore,
) -> MetaResult<CdcTableSnapshotSplitAssignment>