Class: Dynflow::Executors::Sidekiq::InternalJobBase

Inherits:

Object

• Object
• Dynflow::Executors::Sidekiq::InternalJobBase

Extended by:

Serialization::WorkerExtension::ClassMethods

Includes:

Sidekiq::Worker

Defined in:

lib/dynflow/executors/sidekiq/internal_job_base.rb

Direct Known Subclasses

OrchestratorJobs::HandlePersistenceError, OrchestratorJobs::PlanEvent, OrchestratorJobs::StartupComplete, OrchestratorJobs::WorkerDone, WorkerJobs::DrainMarker, WorkerJobs::PerformWork

Class Method Summary

• .inherited(klass) ⇒ Object

Instance Method Summary

• #telemetry_options(work_item) ⇒ Object
• #worker_id ⇒ Object

Methods included from Serialization::WorkerExtension::ClassMethods

client_push

Class Method Details

.inherited(klass) ⇒ Object

# File 'lib/dynflow/executors/sidekiq/internal_job_base.rb', line 10

def self.inherited(klass)
  klass.prepend(::Dynflow::Executors::Sidekiq::Serialization::WorkerExtension)
end

Instance Method Details

#telemetry_options(work_item) ⇒ Object

# 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 ⇒ Object

# File 'lib/dynflow/executors/sidekiq/internal_job_base.rb', line 14

def worker_id
  ::Sidekiq::Logging.tid
end