lib/rocket_job/plugins/job/worker.rb in rocketjob-4.3.0.beta2 vs lib/rocket_job/plugins/job/worker.rb in rocketjob-5.0.0.beta
- old
+ new
@@ -64,21 +64,9 @@
where(:state.in => %i[running paused failed]).each do |job|
job.requeue!(server_name) if job.may_requeue?(server_name)
end
end
- # DEPRECATED
- def perform_later(args, &block)
- if RocketJob::Config.inline_mode
- perform_now(args, &block)
- else
- job = new(args)
- yield(job) if block
- job.save!
- job
- end
- end
-
private
def rocket_job_merge_filter(target, source)
source.each_pair do |k, v|
target[k] =