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

@@ -154,11 +154,16 @@
 
     def enqueue_job(workflow_id, job)
       job.enqueue!
       persist_job(workflow_id, job)
       queue = job.queue || configuration.namespace
-
-      Gush::Worker.set(queue: queue).perform_later(*[workflow_id, job.name])
+      wait = job.wait
+      
+      if wait.present?
+        Gush::Worker.set(queue: queue, wait: wait).perform_later(*[workflow_id, job.name])
+      else
+        Gush::Worker.set(queue: queue).perform_later(*[workflow_id, job.name])
+      end
     end
 
     private
 
     def find_job_by_klass_and_id(workflow_id, job_name)