lib/backburner/allq_wrapper.rb in backburner-allq-1.0.49 vs lib/backburner/allq_wrapper.rb in backburner-allq-1.0.50

@@ -89,10 +89,11 @@
   end
 
   class AllQWrapper
     DEFAULT_TIMEOUT = 17_800
     def initialize(url = 'localhost:8090')
+      puts "URL = #{url}"
       allq_conf = Allq::Configuration.new do |config|
         config.host = url
       end
 
       raw_client = Allq::ApiClient.new(allq_conf)
@@ -117,9 +118,13 @@
       @client.job_delete(job.id)
     end
 
     def release(job, delay = 0)
       @client.release_put(job.id, delay: delay)
+    end
+
+    def set_children_started(parent_job_id)
+      @client.set_children_started_put(parent_job_id)
     end
 
     def bury(job)
       @client.bury_put(job.id)
     end