mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Add Sidekiq::Job#latency, fixes #949
This commit is contained in:
parent
dcf68b9624
commit
f3f8760bcb
2 changed files with 5 additions and 1 deletions
|
@ -202,6 +202,10 @@ module Sidekiq
|
|||
@queue
|
||||
end
|
||||
|
||||
def latency
|
||||
Time.now.to_f - @item['enqueued_at']
|
||||
end
|
||||
|
||||
##
|
||||
# Remove this job from the queue.
|
||||
def delete
|
||||
|
|
|
@ -199,11 +199,11 @@ class TestApi < Minitest::Test
|
|||
end
|
||||
|
||||
it 'can find job by id in sorted sets' do
|
||||
q = Sidekiq::Queue.new
|
||||
job_id = ApiWorker.perform_in(100, 1, 'jason')
|
||||
job = Sidekiq::ScheduledSet.new.find_job(job_id)
|
||||
refute_nil job
|
||||
assert_equal job_id, job.jid
|
||||
assert_in_delta job.latency, 0.0, 0.01
|
||||
end
|
||||
|
||||
it 'can find job by id in queues' do
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue