Блог

 class A
  ....
  def something
    if condition
      mark_completed
      // here I can see the object progress is completed
      CompletionStatsWorker.perform_async(self.id)
    end
  end

  def mark_completed
    self.update_attributes!(progress: 'completed')  
  end
end
 

В рабочем:

 class CompletionStatsWorker
  include Sidekiq::Worker

  def perform(id)
    obj = A.find(id)
    //here I'm getting the progress of the same object as 'progressing'
  end
end
 

Sidekiq каким-то образом извлекает старые данные, даже если они запускаются после успешного обновления поля. Я вижу, что объект updated_at не совпадает с фактическим updated_at значением. Пожалуйста, помогите

это может произойти из sidekiq -за того, что работает быстрее, чем передано в БД, вам следует добавить CompletionStatsWorker.perform_async(self.id) в after_commit обратный вызов или изменить метод на :

   def something
    if condition
      if mark_completed
        // here I can see the object progress is completed
        CompletionStatsWorker.perform_async(self.id)
      end
    end
  end
 

взгляните на документы sidekiq