Esegui codice rails dopo l'aggiornamento di un aggiornamento al database, senza after_commit

Question

Sto provando a combattere alcuni casi di gara con il mio task manager in background. Essenzialmente, ho un oggetto Thing (già esistente) e gli assegno alcune proprietà, quindi lo salvo. Dopo che è stato salvato con le nuove proprietà, lo accodo in Resque, passando l'ID.

thing = Thing.find(1) 
puts thing.foo # outputs "old value" 
thing.foo = "new value" 
thing.save 
ThingProcessor.queue_job(thing.id) 

Il processo in background caricherà l'oggetto dal database utilizzando Thing.find(thing_id).

Il problema è che abbiamo riscontrato che Resque è così veloce nel riprendere il lavoro e nel caricare l'oggetto dall'ID, che carica un oggetto non aggiornato. Quindi all'interno del lavoro, chiamare thing.foo restituirà ancora "valore precedente" come 1/100 volte (non dati reali, ma non succede spesso).

Sappiamo che questo è un caso di gara, perché le rotaie torneranno da thing.saveprima che i dati è stato effettivamente commesso al database (PostgreSQL in questo caso).

Esiste un modo in Rails per eseguire solo il codice DOPO che un'operazione di database è stata eseguita? Essenzialmente, voglio assicurarmi che quando Resque carica l'oggetto, sta ottenendo l'oggetto più fresco. So che questo può essere ottenuto utilizzando un gancio after_commit sul modello Thing, ma non lo voglio lì. Ho solo bisogno che ciò avvenga in questo contesto specifico, non ogni volta che il modello è stato commutato nel DB.

Answer 1

È possibile inserire una transazione. Proprio come nell'esempio qui sotto:

transaction do 
    thing = Thing.find(1) 
    puts thing.foo # outputs "old value" 
    thing.foo = "new value" 
    thing.save 
end 
ThingProcessor.queue_job(thing.id) 

---

Update: c'è una gemma che chiama dopo la transazione, con questo si può risolvere il problema. Ecco il link: http://xtargets.com/2012/03/08/understanding-and-solving-race-conditions-with-ruby-rails-and-background-workers/

Answer 2

Che dire di avvolgere un try intorno al transaction in modo che il lavoro è in coda soltanto in caso di successo della transazione?