Fix iterable jobs cancellation (#6589)

sidekiq · Jan 25, 2025 · e0ccdb0 · e0ccdb0
1 parent 57bdf45
commit e0ccdb0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/sidekiq/job/iterable.rb b/lib/sidekiq/job/iterable.rb
@@ -200,7 +200,7 @@ def iterate_with_enumerator(enumerator, arguments)
           if ::Process.clock_gettime(::Process::CLOCK_MONOTONIC) - state_flushed_at >= STATE_FLUSH_INTERVAL || is_interrupted
             _, _, cancelled = flush_state
             state_flushed_at = ::Process.clock_gettime(::Process::CLOCK_MONOTONIC)
-            if cancelled == 1
+            if cancelled
               @_cancelled = true
               logger.info { "Job cancelled" }
               return true