Merge pull request #44 from controlshift/redis-deprecation-warnings

Fix redis deprecation warnings
gzigzigzeo · Jul 15, 2022 · 14aaf1c · 14aaf1c
2 parents 83fe59c + ed169b5
commit 14aaf1c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/lib/sidekiq/grouping.rb b/lib/sidekiq/grouping.rb
@@ -1,3 +1,4 @@
+require "active_support"
 require "active_support/core_ext/string"
 require "active_support/configurable"
 require "active_support/core_ext/numeric/time"

diff --git a/lib/sidekiq/grouping/redis.rb b/lib/sidekiq/grouping/redis.rb
@@ -13,10 +13,10 @@ class Redis
 
       def push_msg(name, msg, remember_unique = false)
         redis do |conn|
-          conn.multi do
-            conn.sadd(ns('batches'), name)
-            conn.rpush(ns(name), msg)
-            conn.sadd(unique_messages_key(name), msg) if remember_unique
+          conn.multi do |pipeline|
+            pipeline.sadd(ns('batches'), name)
+            pipeline.rpush(ns(name), msg)
+            pipeline.sadd(unique_messages_key(name), msg) if remember_unique
           end
         end
       end