lib/gush/client.rb in gush-0.3.1 vs lib/gush/client.rb in gush-0.3.2
- old
+ new
@@ -141,10 +141,10 @@
private
attr_reader :sidekiq, :redis
def workflow_from_hash(hash, nodes = nil)
- flow = hash[:klass].constantize.new
+ flow = hash[:klass].constantize.new *hash[:arguments]
flow.jobs = []
flow.stopped = hash.fetch(:stopped, false)
flow.id = hash[:id]
(nodes || hash[:nodes]).each do |node|