使用Sidekiq::Testing.fake!时如何复现任务重试行为？

问题根源 #

Sidekiq的Sidekiq::Testing.fake!模式是为了快速模拟任务入队与执行，默认不处理真实Sidekiq的错误重试、延迟调度等后台逻辑。当你调用Worker的drain方法时，任务仅执行一次，报错后直接被丢弃，不会自动加入重试队列（RetrySet）或死信队列（DeadSet），因此你查看这些集合和jobs数组时都会是空的。

复现重试行为的方案 #

由于fake模式本身不支持自动重试，你需要手动模拟重试逻辑，以下是可行的实现方式：

• 手动模拟完整重试流程
  根据Worker的重试配置（比如sidekiq_options retry: 5），在测试中捕获任务执行的错误，然后手动将任务重新入队，直到达到设定的重试次数。示例代码：

  describe YourWorker do
    before do
      Sidekiq::Testing.fake!
      YourWorker.clear
    end
  
    it 'retries up to 5 times when failing' do
      # 初始入队任务
      YourWorker.perform_async(your_args)
  
      # 模拟5次重试流程
      5.times do |retry_count|
        # 执行任务，预期抛出错误
        expect { YourWorker.drain }.to raise_error(YourExpectedError)
        # 最后一次重试失败后不再入队
        YourWorker.perform_async(your_args) unless retry_count == 4
      end
  
      # 验证最终无剩余任务
      expect(YourWorker.jobs.size).to eq(0)
    end
  end
  

• 验证重试配置的简化思路
  如果你只是想验证Worker的重试次数配置是否正确，无需模拟完整执行流程，可以直接断言Worker的重试参数：

  it 'has correct retry configuration' do
    expect(YourWorker.sidekiq_options_hash[:retry]).to eq(5)
  end
  

额外注意事项 #

• 确认你的Worker类已正确配置重试次数，默认情况下Sidekiq的重试次数是25，需确保sidekiq_options retry: 5已生效。
• 在fake模式下，RetrySet和DeadSet不会自动被Sidekiq维护，只有手动向这些集合添加任务时才会有数据，因此直接查询它们的size始终为0是正常的。

内容的提问来源于stack exchange，提问作者Argus9