From c426763c42d41c9c0c9a9cfe544f3185eeaa984f Mon Sep 17 00:00:00 2001
From: Shinya Maeda <gitlab.shinyamaeda@gmail.com>
Date: Wed, 29 Mar 2017 20:49:47 +0900
Subject: Rename ScheduledTrigger to TriggerSchedule. Because table structure
 changed.

---
 app/workers/scheduled_trigger_worker.rb | 18 ------------------
 app/workers/trigger_schedule_worker.rb  | 17 +++++++++++++++++
 2 files changed, 17 insertions(+), 18 deletions(-)
 delete mode 100644 app/workers/scheduled_trigger_worker.rb
 create mode 100644 app/workers/trigger_schedule_worker.rb

(limited to 'app/workers')

diff --git a/app/workers/scheduled_trigger_worker.rb b/app/workers/scheduled_trigger_worker.rb
deleted file mode 100644
index 5c2f03dee79..00000000000
--- a/app/workers/scheduled_trigger_worker.rb
+++ /dev/null
@@ -1,18 +0,0 @@
-class ScheduledTriggerWorker
-  include Sidekiq::Worker
-  include CronjobQueue
-
-  def perform
-    Ci::ScheduledTrigger.where("next_run_at < ?", Time.now).find_each do |trigger|
-      begin
-        Ci::CreatePipelineService.new(trigger.project, trigger.owner, ref: trigger.ref).
-          execute(ignore_skip_ci: true, scheduled_trigger: true)
-      rescue => e
-        Rails.logger.error "#{trigger.id}: Failed to trigger job: #{e.message}"
-      ensure
-        trigger.schedule_next_run!
-        trigger.update_last_run!
-      end
-    end
-  end
-end
diff --git a/app/workers/trigger_schedule_worker.rb b/app/workers/trigger_schedule_worker.rb
new file mode 100644
index 00000000000..d55e9378e02
--- /dev/null
+++ b/app/workers/trigger_schedule_worker.rb
@@ -0,0 +1,17 @@
+class TriggerScheduleWorker
+  include Sidekiq::Worker
+  include CronjobQueue
+
+  def perform
+    Ci::TriggerSchedule.where("next_run_at < ?", Time.now).find_each do |trigger|
+      begin
+        Ci::CreatePipelineService.new(trigger.project, trigger.owner, ref: trigger.ref).
+          execute(ignore_skip_ci: true, scheduled_trigger: true)
+      rescue => e
+        Rails.logger.error "#{trigger.id}: Failed to trigger job: #{e.message}"
+      ensure
+        trigger.schedule_next_run!
+      end
+    end
+  end
+end
-- 
cgit v1.2.3