Sha256: ba3070e9fda9e2a1cbb55cf8b92fcf7423960826c4254ee7d376ef0c4b65cad9
Contents?: true
Size: 1.5 KB
Versions: 10
Compression:
Stored size: 1.5 KB
Contents
# frozen_string_literal: true
module Resque
module Failure
# Provides Resque integration with Airbrake.
#
# @since v5.0.0
# @see https://github.com/resque/resque/wiki/Failure-Backends
class Airbrake < Base
def save
::Airbrake.notify_sync(exception, payload) do |notice|
notice[:context][:component] = 'resque'
notice[:context][:action] = action(payload)
end
end
private
# @return [String] job's name. When ActiveJob is present, retrieve
# job_class. When used directly, use worker's name
def action(payload)
active_job_args = payload['args'].first if payload['args']
if active_job_args.is_a?(Hash) && active_job_args['job_class']
active_job_args['job_class']
else
payload['class'].to_s
end
end
end
end
end
module Resque
# Measures elapsed time of a job and notifies Airbrake of the execution
# status.
#
# @since v9.6.0
class Job
# Store the original method to use it later.
alias perform_without_airbrake perform
def perform
timing = Airbrake::Benchmark.measure do
perform_without_airbrake
end
rescue StandardError => exception
Airbrake.notify_queue_sync(
queue: payload['class'],
error_count: 1,
timing: 0.01,
)
raise exception
else
Airbrake.notify_queue_sync(
queue: payload['class'],
error_count: 0,
timing: timing,
)
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems