class Dynflow::Executors::Sidekiq::InternalJobBase
Public Class Methods
inherited(klass)
click to toggle source
# File lib/dynflow/executors/sidekiq/internal_job_base.rb, line 9 def self.inherited(klass) klass.prepend(::Dynflow::Executors::Sidekiq::Serialization::WorkerExtension) end
Public Instance Methods
telemetry_options(work_item)
click to toggle source
# File lib/dynflow/executors/sidekiq/internal_job_base.rb, line 17 def telemetry_options(work_item) { queue: work_item.queue.to_s, world: Dynflow.process_world.id, worker: worker_id } end
worker_id()
click to toggle source
# File lib/dynflow/executors/sidekiq/internal_job_base.rb, line 13 def worker_id ::Sidekiq::Logging.tid end