class Dynflow::Executors::Sidekiq::InternalJobBase

Public Class Methods

inherited(klass) click to toggle source
# File lib/dynflow/executors/sidekiq/internal_job_base.rb, line 10
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 18
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 14
def worker_id
  ::Sidekiq::Logging.tid
end