diff options
Diffstat (limited to 'vendor/gems/sidekiq-reliable-fetch/tests/interruption/test_kill_signal.rb')
-rwxr-xr-x | vendor/gems/sidekiq-reliable-fetch/tests/interruption/test_kill_signal.rb | 25 |
1 files changed, 25 insertions, 0 deletions
diff --git a/vendor/gems/sidekiq-reliable-fetch/tests/interruption/test_kill_signal.rb b/vendor/gems/sidekiq-reliable-fetch/tests/interruption/test_kill_signal.rb new file mode 100755 index 00000000000..6f61f25970b --- /dev/null +++ b/vendor/gems/sidekiq-reliable-fetch/tests/interruption/test_kill_signal.rb @@ -0,0 +1,25 @@ +# frozen_string_literal: true + +require 'sidekiq' +require_relative 'config' +require_relative '../support/utils' + +EXPECTED_NUM_TIMES_BEEN_RUN = 3 +NUM_WORKERS = EXPECTED_NUM_TIMES_BEEN_RUN + 1 + +Sidekiq.redis(&:flushdb) + +pids = spawn_workers(NUM_WORKERS) + +RetryTestWorker.perform_async + +sleep 300 + +Sidekiq.redis do |redis| + times_has_been_run = redis.get('times_has_been_run').to_i + assert 'The job has been run', times_has_been_run, EXPECTED_NUM_TIMES_BEEN_RUN +end + +assert 'Found interruption exhausted jobs', Sidekiq::InterruptedSet.new.size, 1 + +stop_workers(pids) |