Remove schedules_changed set on startup

schedules_changed's type was changed from SET to ZSET, so we remove old versions at startup
sidekiq-scheduler · Aug 31, 2017 · cc0e348 · cc0e348
1 parent ca4617c
commit cc0e348
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/lib/sidekiq-scheduler.rb b/lib/sidekiq-scheduler.rb
@@ -28,6 +28,9 @@
       listened_queues_only: listened_queues_only
     }
 
+    # schedules_changed's type was changed from SET to ZSET, so we remove old versions at startup
+    Sidekiq.redis { |r| r.del(:schedules_changed) unless r.type(:schedules_changed) == 'zset' }
+
     schedule_manager = SidekiqScheduler::Manager.new(scheduler_options)
     config.options[:schedule_manager] = schedule_manager
     config.options[:schedule_manager].start

diff --git a/lib/sidekiq/scheduler.rb b/lib/sidekiq/scheduler.rb
@@ -74,8 +74,6 @@ def load_schedule!
             end
           end
 
-          Sidekiq.redis { |r| r.del(:schedules_changed) unless r.type(:schedules_changed) == 'zset' }
-
           logger.info 'Schedules Loaded'
         else
           logger.info 'SidekiqScheduler is disabled'