Navigation Menu

Skip to content

Commit

Permalink
Revert "Allow tests to override enqueued_at", fixes #4149
Browse files Browse the repository at this point in the history
This reverts commit cfe53e5.
  • Loading branch information
mperham committed Apr 16, 2019
1 parent 4b23960 commit 0a2559b
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 12 deletions.
2 changes: 1 addition & 1 deletion lib/sidekiq/client.rb
Expand Up @@ -198,7 +198,7 @@ def atomic_push(conn, payloads)
q = payloads.first['queue']
now = Time.now.to_f
to_push = payloads.map do |entry|
entry['enqueued_at'] ||= now
entry['enqueued_at'] = now
Sidekiq.dump_json(entry)
end
conn.sadd('queues', q)
Expand Down
13 changes: 2 additions & 11 deletions test/test_web.rb
Expand Up @@ -107,22 +107,13 @@ def perform(a, b)
end

it 'can display queues' do
assert Sidekiq::Client.push('queue' => :foo, 'class' => WebWorker, 'args' => [1, 3])

get '/queues'
assert_equal 200, last_response.status
assert_match(/foo/, last_response.body)
refute_match(/HardWorker/, last_response.body)
refute_match(/datetime/, last_response.body)
Sidekiq::Queue.new("foo").clear

assert Sidekiq::Client.push('queue' => :foo, 'class' => WebWorker, 'args' => [1, 3], 'enqueued_at' => Time.now.to_f - 65)

get '/queues'
assert_equal 200, last_response.status
assert_match(/foo/, last_response.body)
refute_match(/WebWorker/, last_response.body)
assert_match(/datetime/, last_response.body)
refute_match(/HardWorker/, last_response.body)
assert_match(/seconds ago/, last_response.body)
end

it 'handles queue view' do
Expand Down

0 comments on commit 0a2559b

Please sign in to comment.