Class: Dynflow::Executors::Sidekiq::OrchestratorJobs::PlanEvent

Inherits:

InternalJobBase

• Object
• InternalJobBase
• Dynflow::Executors::Sidekiq::OrchestratorJobs::PlanEvent

Defined in:

lib/dynflow/executors/sidekiq/orchestrator_jobs.rb

Overview

handles setting up an event on orchestrator

Instance Method Summary

• #perform(execution_plan_id, step_id, event, time) ⇒ Object

Methods inherited from InternalJobBase

inherited, #telemetry_options, #worker_id

Methods included from Serialization::WorkerExtension::ClassMethods

#client_push

Instance Method Details

#perform(execution_plan_id, step_id, event, time) ⇒ Object

Parameters:

• event_envelope (Dispatcher::Event) —

  • 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 30

def perform(execution_plan_id, step_id, event, time)
  Dynflow.process_world.plan_event(execution_plan_id, step_id, event, time)
end