diff --git a/app/models/solid_queue/recurring_task.rb b/app/models/solid_queue/recurring_task.rb index d1016991..54777531 100644 --- a/app/models/solid_queue/recurring_task.rb +++ b/app/models/solid_queue/recurring_task.rb @@ -67,11 +67,15 @@ def enqueue(at:) end end - payload[:active_job_id] = active_job.job_id if active_job + active_job.tap do |enqueued_job| + payload[:active_job_id] = enqueued_job.job_id + end rescue RecurringExecution::AlreadyRecorded payload[:skipped] = true + false rescue Job::EnqueueError => error payload[:enqueue_error] = error.message + false end end