lib/gush/workflow.rb in gush-0.4.1 vs lib/gush/workflow.rb in gush-1.0.0

@@ -100,14 +100,13 @@
     def stopped?
       stopped
     end
 
     def run(klass, opts = {})
-      options =
-
-      node = klass.new(self, {
-        name: client.next_free_job_id(id,klass.to_s),
+      node = klass.new({
+        workflow_id: id,
+        name: client.next_free_job_id(id, klass.to_s),
         params: opts.fetch(:params, {})
       })
 
       jobs << node
 
@@ -123,10 +122,15 @@
 
       node.name
     end
 
     def reload
-      self.class.find(id)
+      flow = self.class.find(id)
+
+      self.jobs = flow.jobs
+      self.stopped = flow.stopped
+
+      self
     end
 
     def initial_jobs
       jobs.select(&:has_no_dependencies?)
     end