Prove that errors thrown in read/write jobs clog the queue
Catch errors inside runBatch and re-run to prevent exceptions blocking the flush