6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
# File 'lib/solid_events/subscribers/job_subscriber.rb', line 6
def call(_name, started, finished, _unique_id, payload)
job = payload[:job]
return unless job
trace_name = "job.#{job.class.name.underscore}"
return if SolidEvents.ignore_job_prefixes.any? { |prefix| trace_name.start_with?(prefix.to_s) }
causal = SolidEvents::Tracer.consume_async_causal_link(job_id: job.job_id)
trace = SolidEvents::Tracer.start_trace!(
name: trace_name,
trace_type: "job",
source: job.class.name,
caused_by_trace_id: causal[:trace_id],
caused_by_event_id: causal[:event_id],
context: {
job_id: job.job_id,
queue: job.queue_name,
caused_by_trace_id: causal[:trace_id],
caused_by_event_id: causal[:event_id],
service_name: SolidEvents.service_name,
environment_name: SolidEvents.environment_name,
service_version: SolidEvents.service_version,
deployment_id: SolidEvents.deployment_id,
region: SolidEvents.region
}.compact
)
SolidEvents::Tracer.record_event!(
event_type: "job",
name: job.class.name,
payload: {job_id: job.job_id, queue: job.queue_name},
duration_ms: ((finished - started) * 1000.0).round(2)
)
SolidEvents::Tracer.finish_trace!(status: payload[:exception_object].present? ? "error" : "ok")
trace
end
|