pub fn run_load_cdc(
loader: &dyn TargetLoader,
table: &str,
specs: &[TargetColumnSpec],
uris: &[String],
pk: &[String],
engine: SourceEngine,
expected_delta: Option<u64>,
cleanup: Option<(&GcsStore, &str)>,
) -> Result<CdcLoadReport>