lib/good_job/adapter.rb in good_job-0.1.0 vs lib/good_job/adapter.rb in good_job-0.2.0
- old
+ new
@@ -20,10 +20,17 @@
serialized_params: job.serialize,
}
params[:scheduled_at] = Time.at(timestamp) if timestamp
good_job = GoodJob::Job.create(params)
- @scheduler.enqueue(good_job) if inline?
+ job.provider_job_id = good_job.id
+
+ GoodJob.tag_logger do
+ ActiveSupport::Notifications.instrument("create.good_job", { good_job: good_job, job: job })
+ @scheduler.enqueue(good_job) if inline?
+ end
+
+ good_job
end
def shutdown(wait: true)
@scheduler&.shutdown(wait: wait)
end