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] =