Sidekiqは、労働者には一貫性のないデータ

Question

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は何とかそれが成功したフィールドupdation後にトリガされた場合でも、古いデータを取得します。オブジェクトupdated_atは実際のupdated_atの値と同じではないことがわかります。 sidekiqが速く、それはDBにコミットよりも動作しますので、それが起こることがあり

Answer 1

、あなたがCompletionStatsWorker.perform_async(self.id)after_commitへのコールバックや変更方法を追加する必要があります助けてください：見sidekiq docs