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