Module: Que::RecordJobStatusToParentJob
- Defined in:
- lib/record_job_status_to_parent_job.rb
Instance Method Summary collapse
Instance Method Details
#parent_job_id ⇒ Object
2 3 4 5 6 |
# File 'lib/record_job_status_to_parent_job.rb', line 2 def parent_job_id @attrs['args'].first['parent_job_id'] || 0 rescue 0 end |
#parent_job_scope ⇒ Object
20 21 22 |
# File 'lib/record_job_status_to_parent_job.rb', line 20 def parent_job_scope QueJobStatus.where(job_id: parent_job_id) end |
#update_job_data(job_data) ⇒ Object
8 9 10 11 12 13 14 15 16 17 18 |
# File 'lib/record_job_status_to_parent_job.rb', line 8 def update_job_data(job_data) super if defined?(super) parent_job_scope.find_each do |parent_job| parent_job.with_lock do parent_job.job_data = [] unless parent_job.job_data.kind_of?(Array) parent_job.job_data << job_data parent_job.save! end end end |