Sidekiq 工作人员更改 schema_search_path

Question

我有以下工人：

class ImageWorker
  include Sidekiq::Worker

  def perform(tenant_id, id, key)
    tenant = Tenant.find(tenant_id)
    tenant.scope_schema do
      image = Image.find(id)
      unless image.image_processed?
        image.key = key
        image.remote_image_url = image.image.direct_fog_url(with_path: true)
        image.save!
        image.update_column(:image_processed, true)
      end
    end
  end
end

Tenant#scope_schema 方法如下所示：

def scope_schema(*paths)
  original_search_path = ActiveRecord::Base.connection.schema_search_path
  paths << "extensions"
  ActiveRecord::Base.connection.schema_search_path = ["tenant#{id}", *paths].join(",")
  yield
ensure
  ActiveRecord::Base.connection.schema_search_path = original_search_path
end

当 ImageWorker 作业运行时，它告诉我找不到 id=7 的图像，因此虽然我可以在 Sidekiq 工作人员类之外获取相同的代码并运行，但 scope_schema 似乎不起作用很好。

Answer 1

使用 after_commit 确保作业执行时数据库记录存在。