🏭 feat: Add Safe Parallel Ingestion Consumers (#317)
* feat: add parallel ingestion consumers and logging * updated doc an less logging * batch pipeline now fails fast * Fix parallel ingestion rollback race condition * simplify cleanup tracking * Fix async ingestion rollback guard for failed first batch * Guard async ingestion rollback until an insert succeeds * Track completed shielded inserts before rollback cleanup * fix: clean up cancelled parallel ingestion * fix: harden parallel ingestion failure handling * fix: preserve parallel ingestion context order * fix: close parallel ingestion edge cases --------- Co-authored-by: Peter Rothlaender <peter.rothlaender@ginkgo.com>
D
Danny Avila committed
4985b37b8b5d4519d68eceedfef1e63624012f9d
Parent: 6c77d34
Committed by GitHub <noreply@github.com>
on 7/31/2026, 6:06:44 PM