Module: Dynflow::Executors::Sidekiq::Serialization::WorkerExtension::ClassMethods

Included in:
InternalJobBase
Defined in:
lib/dynflow/executors/sidekiq/serialization.rb

Overview

Overriding the Sidekiq entry method to perform additional serialization preparation

Instance Method Summary collapse

Instance Method Details

#client_push(opts) ⇒ Object 



20
21
22
23
 
# File 'lib/dynflow/executors/sidekiq/serialization.rb', line 20

def client_push(opts)
  opts['args'] = opts['args'].map { |a| Serialization.serialize(a) }
  super(opts)
end