sidekiq - 如何处理嵌套作业的异常？

Question

我有一个 Sidekiq/ActiveJob 类，如下所示:

class ParentJob < ApplicationJob
  queue_as :default

  def perform(user)
    ChildJobA.perform_now(user)
    ChildJobB.perform_now(user)
    ChildJobC.perform_now(user)
    ...
  rescue CustomError => e
    handle_error(e)
  end
end

父作业通过 ParentJob.perform_later(user) 调用.

子工作可以提高 CustomError .我以为我可以拯救那些在 parent 工作中的人——但我的 rescue块永远不会被调用。似乎子作业只是退出并且控制权不会传回父级。

有没有办法挽救父作业中的自定义错误，或者我是否必须在每个子作业中重复相同的错误处理程序？

Answer 1

像普通的 Ruby 代码一样调用它并从图片中删除 ActiveJob:

ChildJobA.new.perform(user)
ChildJobB.new.perform(user)
ChildJobC.new.perform(user)

那应该正常提高。