I have made the suggested changes. Also, I noticed a method called self.cancel_jobs. which can potentially delete records even when a delta job is being processed by any worker. So this may corrupt the indices. Also, failed_at jobs should not be cleared as they will serve debugging purposes.
Pat,
I have made the suggested changes. Also, I noticed a method called self.cancel_jobs. which can potentially delete records even when a delta job is being processed by any worker. So this may corrupt the indices. Also, failed_at jobs should not be cleared as they will serve debugging purposes.