1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00

added support for time as a Numeric

This commit is contained in:
Peter Ohler 2012-08-20 10:19:59 +09:00
parent 8060cac909
commit 2bcae35267
3 changed files with 4 additions and 4 deletions

View file

@ -24,7 +24,7 @@ class TestInline < MiniTest::Unit::TestCase
class InlineWorkerWithTimeParam
include Sidekiq::Worker
def perform(time)
raise ParameterIsNotString unless time.is_a?(String)
raise ParameterIsNotString unless time.is_a?(String) || time.is_a?(Numeric)
end
end

View file

@ -11,4 +11,4 @@ table class="table table-striped table-bordered workers"
td= msg['queue']
td= msg['payload']['class']
td= msg['payload']['args'].inspect[0..100]
td== relative_time(Time.parse(msg['run_at']))
td== relative_time(msg['run_at'].is_a?(Numeric) ? Time.at(msg['run_at']) : Time.parse(msg['run_at']))

View file

@ -22,11 +22,11 @@ header
td= msg['retry_count']
tr
th Last Retry
td== relative_time(Time.parse(msg['retried_at']))
td== relative_time(msg['retried_at'].is_a?(Numeric) ? Time.at(msg['retried_at']) : Time.parse(msg['retried_at']))
- else
tr
th Originally Failed
td== relative_time(Time.parse(msg['failed_at']))
td== relative_time(msg['failed_at'].is_a?(Numeric) ? Time.at(msg['failed_at']) : Time.parse(msg['failed_at']))
tr
th Next Retry
td== relative_time(Time.at(@score))