test with older redis,

Author: onyxraven

.github/workflows/ruby.yml

@@ -38,6 +38,7 @@ jobs:
           - "3.5"
           - "3.6"
         redis-version:
+          - "~> 3.x"
           - "~> 4.x"
           - "~> 5.x"
         exclude:

lib/resque/scheduler/configuration.rb

@@ -76,7 +76,8 @@ def delayed_requeue_batch_size
       attr_writer :disable_delayed_requeue_batches
 
       def disable_delayed_requeue_batches
-        @enable_delayed_requeue_batches ||= to_bool(environment['DISABLE_DELAYED_REQUEUE_BATCH'])
+        @enable_delayed_requeue_batches ||= \
+          to_bool(environment['DISABLE_DELAYED_REQUEUE_BATCH'])
       end
 
       # Amount of time in seconds to sleep between polls of the delayed

test/delayed_queue_test.rb

@@ -1,6 +1,14 @@
 # vim:fileencoding=utf-8
 require_relative 'test_helper'
 
+def assert_resque_key_exists?(key)
+  if Gem::Requirement.create('< 4').satisfied_by?(Gem::Version.create(Redis::VERSION))
+    assert(!Resque.redis.exists(key))
+  else
+    assert(!Resque.redis.exists?(key))
+  end
+end
+
 context 'DelayedQueue' do
   setup do
     Resque::Scheduler.quiet = true
@@ -41,7 +49,7 @@
                  'Should have the same arguments that we queued')
 
     # And now confirm the keys are gone
-    assert(!Resque.redis.exists?("delayed:#{timestamp.to_i}"))
+    assert_resque_key_exists?("delayed:#{timestamp.to_i}")
     assert_equal(0, Resque.redis.zcard(:delayed_queue_schedule),
                  'delayed queue should be empty')
     assert_equal(0, Resque.redis.scard("timestamps:#{encoded_job}"),
@@ -84,7 +92,7 @@
                  'Should have the queue that we asked for')
 
     # And now confirm the keys are gone
-    assert(!Resque.redis.exists?("delayed:#{timestamp.to_i}"))
+    assert_resque_key_exists?("delayed:#{timestamp.to_i}")
     assert_equal(0, Resque.redis.zcard(:delayed_queue_schedule),
                  'delayed queue should be empty')
     assert_equal(0, Resque.redis.scard("timestamps:#{encoded_job}"),
@@ -1108,7 +1116,7 @@
     assert_equal(
       1, Resque.remove_delayed_job_from_timestamp(t, SomeIvarJob, 'foo')
     )
-    assert !Resque.redis.exists?("delayed:#{t.to_i}")
+    assert_resque_key_exists?("delayed:#{t.to_i}")
     assert Resque.delayed_queue_peek(0, 100).empty?
   end
 
@@ -1149,7 +1157,7 @@
       Resque.enqueue_at(timestamp, SomeIvarJob, 'foo', 'bar')
 
       assert_equal 0, Resque.count_all_scheduled_jobs
-      assert !Resque.redis.exists?("delayed:#{timestamp.to_i}")
+      assert_resque_key_exists?("delayed:#{timestamp.to_i}")
     ensure
       Resque.inline = false
     end