Commit a61f8c44 authored by Grzegorz Bizon's avatar Grzegorz Bizon

Enqueue a new stage worker in CI/CD processing queue

parent 2e91f181
...@@ -2,6 +2,8 @@ class StageUpdateWorker ...@@ -2,6 +2,8 @@ class StageUpdateWorker
include Sidekiq::Worker include Sidekiq::Worker
include PipelineQueue include PipelineQueue
enqueue_in group: :processing
def perform(stage_id) def perform(stage_id)
Ci::Stage.find_by(id: stage_id).try do |stage| Ci::Stage.find_by(id: stage_id).try do |stage|
stage.update_status stage.update_status
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment