class Dynflow::Executors::Sidekiq::OrchestratorJobs::StartupComplete
Public Instance Methods
perform(world_id)
click to toggle source
@param request_envelope [Dispatcher::Request] - request to handle on orchestrator side
usually to start new execution or to pass some event
# File lib/dynflow/executors/sidekiq/orchestrator_jobs.rb, line 48 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