lib/backburner/allq_wrapper.rb in backburner-allq-1.0.13 vs lib/backburner/allq_wrapper.rb in backburner-allq-1.0.14

- old
+ new

@@ -121,10 +121,14 @@ def tube_names stats_hash = stats stats_hash.keys end + def tubes + tube_names + end + def peek_buried(tube_name = 'default') job = nil job = @client.peek_get(tube_name, buried: true) return nil if job.body.nil? @@ -246,9 +250,14 @@ sleep(5) retry if retry_count < 4 raise 'Failed to put on allq, we are investigating the problem, please try again' end result + end + + def stats(tube) + final_stats = stats + final_stats[tube] end def stats raw_stats = @admin.stats_get final_stats = {}