Ruby on Rails - 延迟任务 - 任务队列未添加到数据库中

3

当将其守护进程化时,作业队列没有添加到延迟作业表中。但在非守护进程化的情况下可以工作。

我有三个rake任务(a.rake、b.rake、c.rake)。

a.rake中:

task :run_a => :environment do
  A.new.get_a_data
end

class A
 def get_a_data
   ...
   schedule_next_a_job
 end

 def schedule_next_a_job
   get_a_data
 end

handle_asynchronously :get_a_data, :run_at => Proc.new { 2.minutes.from_now }, :queue => 'a'
end

在 b.rake 文件中:
task :run_b => :environment do
  B.new.get_b_data
end

class B
 def get_b_data
  ...
  schedule_next_b_job
 end

 def schedule_next_b_job
   get_b_data
 end

handle_asynchronously :get_b_data, :run_at => Proc.new { 5.minutes.from_now }, :queue => 'b'
end

在c.rake文件中

namespace :run do
  task :start do
  `rake run_a`
  `rake run_b`
  if Rails.env == 'development'
    `QUEUES=a,b rake jobs:work`
  else
    `RAILS_ENV=production bin/delayed_job --queues=a,b start` 
  end

  task :stop do
  `rake jobs:clear`
  end
end

在控制台中,我运行如下命令:
RAILS_ENV=production rake run:start # to start jobs worker
rake run:stop # to clear my jobs worker

在我的延迟作业表中,last_error显示为:

作业加载失败:未定义的类/模块A

作业加载失败:未定义的类/模块B

有人能帮我解决这个问题吗?

提前感谢。


1
你看过这个解决方案了吗? - Gagan Gami
1
@Gagan 是的。require 'my_custom_class' 可以工作!谢谢。 - Peter Prabu
1个回答

2

反序列化错误的一个常见原因是YAML引用了worker不知道的类。如果是这种情况,您可以添加

# file: config/initializers/custom.rb
    require 'my_custom_class'

在工作进程启动时加载my_custom_class,可以强制执行此操作。 参考资料


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接