Module: Julewire::ActiveJob::JobAttributes

Defined in:
lib/julewire/active_job/job_attributes.rb

Class Method Summary collapse

Class Method Details

.call(fields) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/julewire/active_job/job_attributes.rb', line 27

def call(fields)
  Core::Fields::AttributeKeys.fields(
    Core::Fields::AttributeKeys::JOB_SYSTEM => "active_job",
    Core::Fields::AttributeKeys::JOB_NAME => first_value(fields, keys: JOB_NAME_KEYS),
    Core::Fields::AttributeKeys::JOB_ID => first_value(fields, keys: JOB_ID_KEYS),
    Core::Fields::AttributeKeys::JOB_PROVIDER_ID => first_value(fields, keys: JOB_PROVIDER_ID_KEYS),
    Core::Fields::AttributeKeys::JOB_QUEUE_NAME => first_value(fields, keys: JOB_QUEUE_NAME_KEYS),
    Core::Fields::AttributeKeys::JOB_PRIORITY => first_value(fields, keys: JOB_PRIORITY_KEYS),
    Core::Fields::AttributeKeys::JOB_EXECUTION_COUNT => first_value(fields, keys: JOB_EXECUTION_COUNT_KEYS),
    Core::Fields::AttributeKeys::JOB_ENQUEUED_AT => first_value(fields, keys: JOB_ENQUEUED_AT_KEYS),
    Core::Fields::AttributeKeys::JOB_SCHEDULED_AT => first_value(fields, keys: JOB_SCHEDULED_AT_KEYS),
    Core::Fields::AttributeKeys::JOB_STATUS => first_value(fields, keys: JOB_STATUS_KEYS)
  )
end