lib/gush/workflow.rb in gush-2.1.0 vs lib/gush/workflow.rb in gush-3.0.0

@@ -110,10 +110,11 @@
     def run(klass, opts = {})
       node = klass.new({
         workflow_id: id,
         id: client.next_free_job_id(id, klass.to_s),
         params: opts.fetch(:params, {}),
-        queue: opts[:queue]
+        queue: opts[:queue],
+        wait: opts[:wait]
       })
 
       jobs << node
 
       deps_after = [*opts[:after]]