12

我有一个标记为由delayed_job异步处理的函数：

class CapJobs
  def execute(params, id)
    begin
      unless Rails.env == "test"
        Capistrano::CLI.parse(params).execute!
      end
    rescue
      site = Site.find(id)
      site.records.create!(:date => DateTime.now, :action => "Task Failure: #{params[0]}", :type => :failure)    
      site.save
    ensure
      yield id
    end 
  end   
  handle_asynchronously :execute
end

当我运行这个函数时，我传入一个块：

 capjobs = CapJobs.new
 capjobs.execute(parameters, @site.id) do |id|
   asite = Site.find(id)
   asite.records.create!(:date => DateTime.now, :action => "Created", :type => :init)
   asite.status = "On Demo"
   asite.dev = true
   asite.save
 end

在没有延迟作业的情况下运行时效果很好，但是在使用它运行时出现以下错误

2012-08-13T09:24:36-0300: [Worker(delayed_job host:eagle pid:12089)] SitesHelper::CapJobs#execute_without_delay failed with LocalJumpError: no block given (yield) - 0 failed attempts
2012-08-13T09:24:36-0300: [Worker(delayed_job host:eagle pid:12089)] PERMANENTLY removing SitesHelper::CapJobs#execute_without_delay because of 1 consecutive failures.
2012-08-13T09:24:36-0300: [Worker(delayed_job host:eagle pid:12089)] 1 jobs processed at 0.0572 j/s, 1 failed ...

似乎没有拿起传入的块。这不是正确的方法还是我应该找到不同的方法？

4

3 回答 3

10

delay_job 的工作原理是将您的作业保存到数据存储（通常是您的主数据库）中，然后将作业从该数据存储中加载到后台进程中，并在其中处理/执行。

要将作业保存到数据库中，delayed_job 需要以某种方式保存使用什么参数调用哪个对象的方法。这是通过将所有内容序列化为字符串来完成的（delayed_job 为此使用yaml）。不幸的是，块不能被序列化。所以后台工作人员不知道 block 参数并在没有它的情况下调用方法。这导致LocalJumpError该方法何时尝试让步到该块。

于 2012-08-13T15:52:43.673 回答
2

我找到了一种方法。这有点hacky，但效果很好。我发现这篇关于创建 SerializableProc 类的文章。如果我将它传递给函数，那么一切都会很好。

于 2012-08-13T17:15:18.143 回答
0

大多数人会将其视为抽象问题。

proc 代码可能不会从运行到运行（vars 除外）发生变化，因此您应该将块代码转换为类或实例方法。传递该方法的名称，然后在您的execute方法中调用它，例如

@some_data = CapJobs.send( target_method )

或者甚至更好

@some_data = DomainSpecificModel.send( target_method )

于 2012-09-17T15:13:08.313 回答