使用delayed_job 的ActiveJob 不会在测试中创建delayed_jobs 行答案

【问题标题】：ActiveJob using delayed_job does not create delayed_jobs row in test使用delayed_job 的ActiveJob 不会在测试中创建delayed_jobs 行
【发布时间】：2017-12-22 04:42:34
【问题描述】：

在 Rails 4.2.3 下，我已设置 ActiveJob 以在所有环境中使用延迟作业作为其后端：

环境.rb

require File.expand_path('../boot', __FILE__)

require 'rails/all'

# Require the gems listed in Gemfile, including any gems
# you've limited to :test, :development, or :production.
Bundler.require(*Rails.groups)

module MyApp
  class Application < Rails::Application
    # ... snip
    # Use delayed_job for Active Job queueing
    config.active_job.queue_adapter = :delayed_job
  end
end

（并且 queue_adapter 在配置下没有另外设置）。

我已按如下方式配置了我的 DelayedJob 实例 - 包括来自 this question 的代码以向后移植 Rails 5 获取作业数据库行的功能：

config/delayed_job.rb

Delayed::Worker.destroy_failed_jobs = false
Delayed::Worker.sleep_delay = 60
Delayed::Worker.max_attempts = 3
Delayed::Worker.max_run_time = 5.minutes
Delayed::Worker.read_ahead = 10
# Delayed::Worker.delay_jobs = true #!Rails.env.test?
Delayed::Worker.logger = Logger.new(Rails.root.join('log', 'delayed_job.log'))

class Delayed::Job < ActiveRecord::Base
  belongs_to :owner, polymorphic: true
end

# Backport Rails 5 code to make the Delayed::Job database id avilable on ActiveJobs
module ActiveJob
  module Core
    # ID optionally provided by adapter
    attr_accessor :provider_job_id
  end

  module QueueAdapters
    class DelayedJobAdapter
      class << self
        send(:prepend, Module.new do
          def enqueue(job)
            provider_job = super
            job.provider_job_id = provider_job.id
            provider_job
          end

          def enqueue_at(job, timestamp)
            provider_job = super
            job.provider_job_id = provider_job.id
            provider_job
          end
        end)
      end
    end
  end
end

我有稍后执行工作的模型代码，并将Delayed::Job 实例挂钩到模型实例：

app/models/my_model.rb

def schedule
  job = MyJob.set(wait_until: scheduled_time).perform_later(self)

  # Associate the delayed_job object with the item that has been scheduled
  delayed_job = Delayed::Job.find(job.provider_job_id)
  delayed_job.owner = self
  delayed_job.save
end

（并且我已经为Delayed::Job 建立了适当的关联）。

这似乎在开发中运行良好；但在测试中，Delayed::Job.find(job.provider_job_id) 失败并引发异常，因为provider_job_id 为零。检查日志显示delayed_jobs 表没有SQL INSERT。

为什么在测试中没有创建延迟作业行？

【问题讨论】：

标签： ruby-on-rails delayed-job ruby-on-rails-4.2 rails-activejob

【解决方案1】：

我遇到了同样的问题。事实证明，ActiveJob::TestCase 劫持了 perform_later 逻辑，实际上并没有将它们排队，而是将有关排队作业的数据存储在一个数组中 (see here)。

我的解决方案是编写一个继承自 ActiveSupport::TestCase 的测试，这似乎像往常一样排队延迟的作业。我相信有一些测试设置会强制内联执行作业，但据我所知，默认行为是将它们排队，因此它应该可以按预期工作而无需太多修改。

【讨论】：