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 = {}