lib/gush/client.rb in gush-0.1.1 vs lib/gush/client.rb in gush-0.1.2

- old
+ new

@@ -115,19 +115,19 @@ persist_job(workflow_id, job) sidekiq.push( 'class' => Gush::Worker, 'queue' => configuration.namespace, - 'args' => [workflow_id, job.class.to_s, configuration.to_json] + 'args' => [workflow_id, job.class.to_s] ) end private attr_reader :sidekiq, :redis def workflow_from_hash(hash, nodes = nil) - flow = hash[:klass].constantize.new(false) + flow = hash[:klass].constantize.new flow.stopped = hash.fetch(:stopped, false) flow.id = hash[:id] (nodes || hash[:nodes]).each do |node| flow.jobs << Gush::Job.from_hash(flow, node)