測試sidekiq工人和retryset Rails的MINITEST

Question

我有一個sidekiq middlware其中趕上自定義異常

require 'celluloid' 
require 'sidekiq/middleware/server/retry_jobs' 

module Sidekiq 
    class RetryMiddleware < Sidekiq::Middleware::Server::RetryJobs 

    def call(worker, msg, queue) 
     yield 
    rescue Sidekiq::Shutdown 
     # ignore, will be pushed back onto queue during hard_shutdown 
     raise 
    rescue Sidekiq::Retries::Retry => e 
     # force a retry (for workers that have retries disabled) 
     msg['retry'] = e.max_retries 
     attempt_retry(worker, msg, queue, e.cause) 
     raise e.cause 
    rescue Sidekiq::Retries::Fail => e 
     # seriously, don't retry this 
     raise e.cause 
    rescue Exception => e 
     # ignore, will be pushed back onto queue during hard_shutdown 
     raise Sidekiq::Shutdown if exception_caused_by_shutdown?(e) 
     raise e unless msg['retry'] 
     attempt_retry(worker, msg, queue, e) 
     raise e 
    end 

    end 
end 

和我的工作人員看起來像下面

class SomeWorker 
    include Sidekiq::Worker 
    sidekiq_options retry: false 

    def perform(input_data) 
    begin 
    logic to insert data into db 
    rescue Ione::Io::ConnectionClosedError => e 
    raise Sidekiq::Retries::Retry 
    end 
    end 

end 

當我試圖測試SomeWorker [執行方法添加作業以重試。 在測試中我沒有看到中間件獲取調用預先

Answer 1

你對自己做出這種方式太辛苦

謝謝，只是調用的方法。

RetryMiddleware.new.call(MyWorker.new, { ... }, 'default') do 
    MyWorker.new.perform(...) 
end