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 49
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