lib/rekiq/scheduler.rb in rekiq-1.1.0 vs lib/rekiq/scheduler.rb in rekiq-1.2.0
- old
+ new
@@ -22,19 +22,16 @@
def schedule_work
@work_time.nil? ? nil : [push_to_redis, @work_time]
end
def push_to_redis
- client_args = {
- 'at' => @work_time.to_f,
- 'queue' => @queue,
- 'class' => @worker_name,
- 'args' => @args,
- 'rq:ctr' => @contract.to_hash,
- 'rq:sdl' => nil,
- 'rq:at' => @work_time.to_f # this needs to be here because the key 'at' is removed by sidekiq
- }
-
- Sidekiq::Client.push(client_args)
+ Sidekiq::Client
+ .push 'at' => @work_time.to_f,
+ 'queue' => @queue,
+ 'class' => @worker_name,
+ 'args' => @args,
+ 'rq:ctr' => @contract.to_hash,
+ 'rq:sdl' => nil,
+ 'rq:at' => @work_time.to_f # this needs to be here because the key 'at' is removed by sidekiq
end
end
end
\ No newline at end of file