From 5406a5a1cf9b56bb3ab8eaa6915f949918ca00ac Mon Sep 17 00:00:00 2001 From: Unknown Date: Thu, 13 Jun 2019 11:17:04 -0600 Subject: [PATCH] Allow Additional Delayed Job Options --- lib/delayed/recurring_job.rb | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/lib/delayed/recurring_job.rb b/lib/delayed/recurring_job.rb index e87cb9a..cdf7183 100644 --- a/lib/delayed/recurring_job.rb +++ b/lib/delayed/recurring_job.rb @@ -37,8 +37,9 @@ def schedule! options = {} queue: self.class.queue ) - enqueue_opts = { priority: @schedule_options[:priority], run_at: next_run_time } - enqueue_opts[:queue] = @schedule_options[:queue] if @schedule_options[:queue] + base_opts = {run_at: next_run_time} + filtered_schedule_options = @schedule_options.except(:run_at, :timezone, :run_interval) + enqueue_opts = base_opts.merge(filtered_schedule_options) Delayed::Job.transaction do self.class.jobs(@schedule_options).destroy_all