class Dynflow::Executors::Parallel::Worker
Public Class Methods
new(pool, transaction_adapter)
click to toggle source
# File lib/dynflow/executors/parallel/worker.rb, line 6 def initialize(pool, transaction_adapter) @pool = Type! pool, Concurrent::Actor::Reference @transaction_adapter = Type! transaction_adapter, TransactionAdapters::Abstract end
Public Instance Methods
on_message(message)
click to toggle source
# File lib/dynflow/executors/parallel/worker.rb, line 11 def on_message(message) match message, (on Work::Step.(step: ~any) | Work::Event.(step: ~any, event: Parallel::Event.(event: ~any)) do |step, event| step.execute event end), (on Work::Finalize.(~any, any) do |sequential_manager| sequential_manager.finalize end) rescue Errors::PersistenceError => e @pool.tell([:handle_persistence_error, e]) ensure @pool.tell([:worker_done, reference, message]) @transaction_adapter.cleanup end