We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a66dc8e commit 35052d5Copy full SHA for 35052d5
lib/async_observer/worker.rb
@@ -208,9 +208,9 @@ def run_ao_job(job)
208
f.call(job) if f
209
job.delete if job.ybody[:delete_first]
210
run_code(job)
211
- job.delete() unless jobs.ybody[:delete_first]
+ job.delete() unless job.ybody[:delete_first]
212
rescue ActiveRecord::RecordNotFound => ex
213
- unless jobs.ybody[:delete_first]
+ unless job.ybody[:delete_first]
214
if job.age > 60
215
job.delete() # it's old; this error is most likely permanent
216
else
0 commit comments