Extract updating pipeline status to async worker

2 files changed, 16 insertions, 9 deletions

diff --git a/app/workers/process_pipeline_worker.rb b/app/workers/process_pipeline_worker.rb
index fa1251b8e9f..9aad8cf818f 100644
--- a/app/workers/process_pipeline_worker.rb
+++ b/app/workers/process_pipeline_worker.rb
@@ -3,15 +3,10 @@ class ProcessPipelineWorker
 
   sidekiq_options queue: :default
 
-  def perform(pipeline_id, params)
-    begin
-      pipeline = Ci::Pipeline.find(pipeline_id)
-    rescue ActiveRecord::RecordNotFound
-      return
-    end
+  def perform(pipeline_id)
+    pipeline = Ci::Pipeline.find_by(id: pipeline_id)
+    return unless pipeline
 
-    pipeline.process! if params['process']
-
-    pipeline.update_status
+    pipeline.process!
   end
 end
diff --git a/app/workers/update_pipeline_worker.rb b/app/workers/update_pipeline_worker.rb
new file mode 100644
index 00000000000..31d29d0ab1c
--- /dev/null
+++ b/app/workers/update_pipeline_worker.rb
@@ -0,0 +1,12 @@
+class UpdatePipelineWorker
+  include Sidekiq::Worker
+
+  sidekiq_options queue: :default
+
+  def perform(pipeline_id)
+    pipeline = Ci::Pipeline.find_by(id: pipeline_id)
+    return unless pipeline
+
+    pipeline.update_status
+  end
+end