Replace Redis pipeline with multi in register_job_instance.

sidekiq-scheduler · May 16, 2024 · 1e8d186 · 1e8d186
1 parent cc4edc8
commit 1e8d186
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/sidekiq-scheduler/redis_manager.rb b/lib/sidekiq-scheduler/redis_manager.rb
@@ -130,9 +130,9 @@ def self.clean_schedules_changed
     def self.register_job_instance(job_name, time)
       job_key = pushed_job_key(job_name)
       registered, _ = Sidekiq.redis do |r|
-        r.pipelined do |pipeline|
-          pipeline.zadd(job_key, time.to_i, time.to_i)
-          pipeline.expire(job_key, REGISTERED_JOBS_THRESHOLD_IN_SECONDS)
+        r.multi do |m|
+          m.zadd(job_key, time.to_i, time.to_i)
+          m.expire(job_key, REGISTERED_JOBS_THRESHOLD_IN_SECONDS)
         end
       end