Class: Dynflow::Executors::Sidekiq::OrchestratorJobs::StartupComplete

Inherits:
InternalJobBase
  • Object
show all
Defined in:
lib/dynflow/executors/sidekiq/orchestrator_jobs.rb

Instance Method Summary collapse

Methods inherited from InternalJobBase

inherited, #telemetry_options, #worker_id

Methods included from Serialization::WorkerExtension::ClassMethods

#client_push

Instance Method Details

#perform(world_id) ⇒ Object

Parameters:

  • request_envelope (Dispatcher::Request) —

    • request to handle on orchestrator side

    usually to start new execution or to pass some event



50
51
52
53
54
55
56
 
# File 'lib/dynflow/executors/sidekiq/orchestrator_jobs.rb', line 50

def perform(world_id)
  if Dynflow.process_world.id == world_id
    Dynflow.process_world.executor.core.tell([:startup_complete])
  else
    logger.warn("Received startup complete for a different world #{world_id}, discarding.")
  end
end