pub async fn apply_postgres_extraction_backfill_batch(
pool: &PgPool,
run: ExtractionBackfillRun,
request: ExtractionBackfillRequest,
) -> Result<ExtractionBackfillRun, ExtractionBackfillError>Expand description
Atomically persists destination records, the batch receipt, and the next checkpoint in PostgreSQL. The run row is locked and compared by digest so a restarted or concurrent orchestrator cannot overwrite newer progress.