Sha256: f22e203a2afa8c49c5a2aff72b3270e5abf9ee391d6e5aba14b380dcbfdc88e6
Contents?: true
Size: 668 Bytes
Versions: 25
Compression:
Stored size: 668 Bytes
Contents
# frozen_string_literal: true
module Dynflow
module Executors
module Sidekiq
class InternalJobBase
include ::Sidekiq::Worker
extend ::Dynflow::Executors::Sidekiq::Serialization::WorkerExtension::ClassMethods
sidekiq_options retry: false, backtrace: true
def self.inherited(klass)
klass.prepend(::Dynflow::Executors::Sidekiq::Serialization::WorkerExtension)
end
def worker_id
::Sidekiq::Logging.tid
end
def telemetry_options(work_item)
{ queue: work_item.queue.to_s, world: Dynflow.process_world.id, worker: worker_id }
end
end
end
end
end
Version data entries
25 entries across 25 versions & 1 rubygems