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)