diff options
| author | Rafael França <rafaelmfranca@gmail.com> | 2018-09-10 17:50:37 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-09-10 17:50:37 -0400 |
| commit | 66ab9c74dd6232e85952e7324fcb130b33576d38 (patch) | |
| tree | 77d6285f26f90d84fad6272170dc3a39f2cec19e /activejob/lib/active_job | |
| parent | 621a4e77cf0b245ae740b2ff1bab5e356363ab45 (diff) | |
| parent | fc4e7d44c8cd9e0521fbd259ec241c4ba56f1db7 (diff) | |
| download | rails-66ab9c74dd6232e85952e7324fcb130b33576d38.tar.gz rails-66ab9c74dd6232e85952e7324fcb130b33576d38.tar.bz2 rails-66ab9c74dd6232e85952e7324fcb130b33576d38.zip | |
Merge pull request #33823 from stoodfarback/aj_backburner_fix_priority
ActiveJob Backburner adapter: fix priority
Diffstat (limited to 'activejob/lib/active_job')
| -rw-r--r-- | activejob/lib/active_job/queue_adapters/backburner_adapter.rb | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/activejob/lib/active_job/queue_adapters/backburner_adapter.rb b/activejob/lib/active_job/queue_adapters/backburner_adapter.rb index 0ba93c6e0b..7dc49310ac 100644 --- a/activejob/lib/active_job/queue_adapters/backburner_adapter.rb +++ b/activejob/lib/active_job/queue_adapters/backburner_adapter.rb @@ -16,12 +16,12 @@ module ActiveJob # Rails.application.config.active_job.queue_adapter = :backburner class BackburnerAdapter def enqueue(job) #:nodoc: - Backburner::Worker.enqueue JobWrapper, [ job.serialize ], queue: job.queue_name + Backburner::Worker.enqueue(JobWrapper, [job.serialize], queue: job.queue_name, pri: job.priority) end def enqueue_at(job, timestamp) #:nodoc: delay = timestamp - Time.current.to_f - Backburner::Worker.enqueue JobWrapper, [ job.serialize ], queue: job.queue_name, delay: delay + Backburner::Worker.enqueue(JobWrapper, [job.serialize], queue: job.queue_name, pri: job.priority, delay: delay) end class JobWrapper #:nodoc: |