diff --git a/app/workers/scheduler/indexing_scheduler.rb b/app/workers/scheduler/indexing_scheduler.rb index ff1b744442e9c7..19cac746826874 100644 --- a/app/workers/scheduler/indexing_scheduler.rb +++ b/app/workers/scheduler/indexing_scheduler.rb @@ -17,7 +17,9 @@ def perform with_redis do |redis| redis.sscan_each("chewy:queue:#{type.name}", count: SCAN_BATCH_SIZE).each_slice(IMPORT_BATCH_SIZE) do |ids| type.import!(ids) - + rescue => e + Rails.logger.error("Error while running #{type.name}#import!: #{e}") + ensure redis.srem("chewy:queue:#{type.name}", ids) end end