fix specs

que-rb · Sep 24, 2024 · 08f868d · 08f868d
1 parent 9c27735
commit 08f868d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/lib/que/locker.rb b/lib/que/locker.rb
@@ -209,9 +209,9 @@ def initialize(
               if poll
                 @queues.map do |queue_name, interval|
                   Poller.new(
-                    connection:    @connection,
-                    queue:         queue_name,
-                    poll_interval: interval,
+                    connection:             @connection,
+                    queue:                  queue_name,
+                    poll_interval:          interval,
                     poll_interval_variance: poll_interval_variance,
                   )
                 end

diff --git a/spec/que/poller_spec.rb b/spec/que/poller_spec.rb
@@ -44,6 +44,7 @@ def poll(
         connection: override_connection || connection,
         queue: queue_name,
         poll_interval: 5,
+        poll_interval_variance: 0,
       )
 
     Que::Poller.setup(override_connection || connection)
@@ -245,6 +246,7 @@ def assert_poll(priorities:, locked:)
         connection: connection,
         queue: 'default',
         poll_interval: 5,
+        poll_interval_variance: 0,
       )
     end