Class: Dynflow::Executors::Sidekiq::OrchestratorJobs::HandlePersistenceError

Inherits:

InternalJobBase

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

Defined in:

lib/dynflow/executors/sidekiq/orchestrator_jobs.rb

Instance Method Summary

• #perform(error, work_item) ⇒ Object

Methods inherited from InternalJobBase

inherited, #telemetry_options, #worker_id

Methods included from Serialization::WorkerExtension::ClassMethods

#client_push

Instance Method Details

#perform(error, work_item) ⇒ Object

Parameters:

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

def perform(error, work_item)
  Dynflow.process_world.executor.core.tell([:handle_persistence_error, error, work_item])
end