diff options
| -rw-r--r-- | lib/active_job/queue_adapters/que_adapter.rb | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/active_job/queue_adapters/que_adapter.rb b/lib/active_job/queue_adapters/que_adapter.rb index 3d30b2bc72..4af3a0fbcf 100644 --- a/lib/active_job/queue_adapters/que_adapter.rb +++ b/lib/active_job/queue_adapters/que_adapter.rb @@ -5,7 +5,7 @@ module ActiveJob class QueAdapter class << self def enqueue(job, *args) - JobWrapper.enqueue job, *args, queue: job.queue_name + JobWrapper.enqueue job.to_s, *args, queue: job.queue_name end def enqueue_at(job, timestamp, *args) @@ -15,7 +15,7 @@ module ActiveJob class JobWrapper < Que::Job def run(job, *args) - job.new.execute *args + job.constantize.new.execute *args end end end |