Add context to the PipelineScheduleWorker

Jobs that could be scheduled from this cron worker:

- RunPipelineScheduleWorker
- BuildHooksWorker
- ExpireJobCacheWorker
- StageUpdateWorker
- PipelineUpdateWorker
- BuildQueueWorker
- ExpirePipelineCacheWorker
- PipelineHooksWorker
- PipelineProcessWorker
- Ci::BuildScheduleWorker
...

app/models/ci/pipeline_schedule.rb

@@ -23,7 +23,7 @@ module Ci
 
     scope :active, -> { where(active: true) }
     scope :inactive, -> { where(active: false) }
-    scope :preloaded, -> { preload(:owner, :project) }
+    scope :preloaded, -> { preload(:owner, project: [:route]) }
 
     accepts_nested_attributes_for :variables, allow_destroy: true
 

app/workers/pipeline_schedule_worker.rb

@@ -2,7 +2,7 @@
 
 class PipelineScheduleWorker
   include ApplicationWorker
-  include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
+  include CronjobQueue
 
   feature_category :continuous_integration
   worker_resource_boundary :cpu
@@ -10,8 +10,10 @@ class PipelineScheduleWorker
   def perform
     Ci::PipelineSchedule.runnable_schedules.preloaded.find_in_batches do |schedules|
       schedules.each do |schedule|
+        with_context(project: schedule.project, user: schedule.owner) do
           Ci::PipelineScheduleService.new(schedule.project, schedule.owner).execute(schedule)
         end
       end
     end
+  end
 end

spec/models/ci/pipeline_schedule_spec.rb

@@ -80,9 +80,9 @@ describe Ci::PipelineSchedule do
     it 'preloads the associations' do
       subject
 
-      query = ActiveRecord::QueryRecorder.new { subject.each(&:project) }
+      query = ActiveRecord::QueryRecorder.new { subject.map(&:project).each(&:route) }
 
-      expect(query.count).to eq(2)
+      expect(query.count).to eq(3)
     end
   end