From 3b4ae571e625b5adabfbb28debb15481bce0aed6 Mon Sep 17 00:00:00 2001 From: Ushitora Anqou Date: Sat, 22 Apr 2023 14:20:58 +0900 Subject: [PATCH] [Scheduler::IndexingScheduler] Ignore import! exceptions --- app/workers/scheduler/indexing_scheduler.rb | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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