diff options
| -rw-r--r-- | lib/active_job/queue_adapters/que_adapter.rb | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/lib/active_job/queue_adapters/que_adapter.rb b/lib/active_job/queue_adapters/que_adapter.rb index 4af3a0fbcf..15a607bcb6 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.to_s, *args, queue: job.queue_name + JobWrapper.enqueue job.name, *args, queue: job.queue_name end def enqueue_at(job, timestamp, *args) @@ -14,8 +14,8 @@ module ActiveJob end class JobWrapper < Que::Job - def run(job, *args) - job.constantize.new.execute *args + def run(job_name, *args) + job_name.constantize.new.execute *args end end end |