diff options
| author | Shinya Maeda <gitlab.shinyamaeda@gmail.com> | 2017-03-31 13:08:39 +0300 |
|---|---|---|
| committer | Shinya Maeda <gitlab.shinyamaeda@gmail.com> | 2017-04-06 17:46:58 +0300 |
| commit | d65c816ed78910eabd7ecbc9282e85d6b6f21796 (patch) | |
| tree | 2b9bd6642ec62484b783f5b6c38c1471c7a3b405 /app/workers | |
| parent | 9573bb44bc94261814dbdbb384b9ad7acf2907ff (diff) | |
Brush up
Diffstat (limited to 'app/workers')
| -rw-r--r-- | app/workers/trigger_schedule_worker.rb | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/app/workers/trigger_schedule_worker.rb b/app/workers/trigger_schedule_worker.rb index 440c579b99d..9216103b8da 100644 --- a/app/workers/trigger_schedule_worker.rb +++ b/app/workers/trigger_schedule_worker.rb @@ -4,11 +4,14 @@ class TriggerScheduleWorker def perform Ci::TriggerSchedule.where("next_run_at < ?", Time.now).find_each do |trigger_schedule| + next if Ci::Pipeline.where(project: trigger_schedule.project, ref: trigger_schedule.ref).running_or_pending.count > 0 + begin Ci::CreateTriggerRequestService.new.execute(trigger_schedule.project, trigger_schedule.trigger, trigger_schedule.ref) rescue => e + puts "#{trigger_schedule.id}: Failed to trigger_schedule job: #{e.message}" # TODO: Remove before merge Rails.logger.error "#{trigger_schedule.id}: Failed to trigger_schedule job: #{e.message}" ensure trigger_schedule.schedule_next_run! |