Make pipeline processing asynchronous

1 files changed, 5 insertions, 12 deletions

diff --git a/app/models/commit_status.rb b/app/models/commit_status.rb
index c85561291c8..e2009b9194b 100644
--- a/app/models/commit_status.rb
+++ b/app/models/commit_status.rb
@@ -70,21 +70,14 @@ class CommitStatus < ActiveRecord::Base
     end
 
     after_transition do |commit_status, transition|
-      commit_status.pipeline.try(:build_updated) unless transition.loopback?
-    end
+      if commit_status.pipeline && !transition.loopback?
+        ProcessPipelineWorker.perform_async(
+          commit_status.pipeline.id,
+          process: HasStatus.COMPLETED_STATUSES.include?(commit_status.status))
+      end
 
-    after_transition any => [:success, :failed, :canceled] do |commit_status|
-      commit_status.pipeline.try(:process!)
       true
     end
-
-    after_transition [:created, :pending, :running] => :success do |commit_status|
-      MergeRequests::MergeWhenBuildSucceedsService.new(commit_status.pipeline.project, nil).trigger(commit_status)
-    end
-
-    after_transition any => :failed do |commit_status|
-      MergeRequests::AddTodoWhenBuildFailsService.new(commit_status.pipeline.project, nil).execute(commit_status)
-    end
   end
 
   delegate :sha, :short_sha, to: :pipeline