Adds some better error handling in ingestion workers.