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 collapse
Instance Method Summary collapse
Methods included from Serialization::WorkerExtension::ClassMethods
Class Method Details
.inherited(klass) ⇒ Object
11 12 13 |
# File 'lib/dynflow/executors/sidekiq/internal_job_base.rb', line 11 def self.inherited(klass) klass.prepend(::Dynflow::Executors::Sidekiq::Serialization::WorkerExtension) end |
Instance Method Details
#telemetry_options(work_item) ⇒ Object
19 20 21 |
# File 'lib/dynflow/executors/sidekiq/internal_job_base.rb', line 19 def (work_item) { queue: work_item.queue.to_s, world: Dynflow.process_world.id, worker: worker_id } end |
#worker_id ⇒ Object
15 16 17 |
# File 'lib/dynflow/executors/sidekiq/internal_job_base.rb', line 15 def worker_id ::Sidekiq::Logging.tid end |