| ... | ... | @@ -3,20 +3,26 @@ |
|
|
|
class PipelineScheduleWorker
|
|
|
|
include ApplicationWorker
|
|
|
|
include CronjobQueue
|
|
|
|
include ::Gitlab::ExclusiveLeaseHelpers
|
|
|
|
|
|
|
|
EXCLUSIVE_LOCK_KEY = 'pipeline_schedules:run:lock'
|
|
|
|
LOCK_TIMEOUT = 50.minutes
|
|
|
|
|
|
|
|
# rubocop: disable CodeReuse/ActiveRecord
|
|
|
|
def perform
|
|
|
|
in_lock(EXCLUSIVE_LOCK_KEY, ttl: LOCK_TIMEOUT, retries: 1) do
|
|
|
|
Ci::PipelineSchedule.active.where("next_run_at < ?", Time.now)
|
|
|
|
.preload(:owner, :project).find_each do |schedule|
|
|
|
|
|
|
|
|
schedule.schedule_next_run!
|
|
|
|
|
|
|
|
Ci::CreatePipelineService.new(schedule.project,
|
|
|
|
schedule.owner,
|
|
|
|
ref: schedule.ref)
|
|
|
|
.execute!(:schedule, ignore_skip_ci: true, save_on_errors: true, schedule: schedule)
|
|
|
|
rescue => e
|
|
|
|
error(schedule, e)
|
|
|
|
ensure
|
|
|
|
schedule.schedule_next_run!
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
# rubocop: enable CodeReuse/ActiveRecord
|
| ... | ... | |
| ... | ... | |