Commit b94e0dc8 authored by Fabio Pitino's avatar Fabio Pitino

Merge branch '232806-ci-worker-removals' into 'master'

Remove PipelineUpdateWorker and PipelineProcessWorker build_ids Argument

See merge request gitlab-org/gitlab!63323
parents bc6d1e35 5e2dbc0e
...@@ -1622,15 +1622,6 @@ ...@@ -1622,15 +1622,6 @@
:weight: 5 :weight: 5
:idempotent: :idempotent:
:tags: [] :tags: []
- :name: pipeline_processing:pipeline_update
:worker_name: PipelineUpdateWorker
:feature_category: :continuous_integration
:has_external_dependencies:
:urgency: :high
:resource_boundary: :unknown
:weight: 5
:idempotent: true
:tags: []
- :name: pipeline_processing:stage_update - :name: pipeline_processing:stage_update
:worker_name: StageUpdateWorker :worker_name: StageUpdateWorker
:feature_category: :continuous_integration :feature_category: :continuous_integration
......
...@@ -13,9 +13,7 @@ class PipelineProcessWorker # rubocop:disable Scalability/IdempotentWorker ...@@ -13,9 +13,7 @@ class PipelineProcessWorker # rubocop:disable Scalability/IdempotentWorker
data_consistency :delayed, feature_flag: :load_balancing_for_pipeline_process_worker data_consistency :delayed, feature_flag: :load_balancing_for_pipeline_process_worker
# rubocop: disable CodeReuse/ActiveRecord # rubocop: disable CodeReuse/ActiveRecord
# `_build_ids` is deprecated and will be removed in 14.0 def perform(pipeline_id)
# See: https://gitlab.com/gitlab-org/gitlab/-/issues/232806
def perform(pipeline_id, _build_ids = nil)
Ci::Pipeline.find_by(id: pipeline_id).try do |pipeline| Ci::Pipeline.find_by(id: pipeline_id).try do |pipeline|
Ci::ProcessPipelineService Ci::ProcessPipelineService
.new(pipeline) .new(pipeline)
......
# frozen_string_literal: true
# This worker is deprecated and will be removed in 14.0
# See: https://gitlab.com/gitlab-org/gitlab/-/issues/232806
class PipelineUpdateWorker
include ApplicationWorker
sidekiq_options retry: 3
include PipelineQueue
queue_namespace :pipeline_processing
urgency :high
idempotent!
def perform(_pipeline_id)
# no-op
end
end
...@@ -371,7 +371,6 @@ RSpec.describe 'Every Sidekiq worker' do ...@@ -371,7 +371,6 @@ RSpec.describe 'Every Sidekiq worker' do
'PipelineMetricsWorker' => 3, 'PipelineMetricsWorker' => 3,
'PipelineNotificationWorker' => 3, 'PipelineNotificationWorker' => 3,
'PipelineProcessWorker' => 3, 'PipelineProcessWorker' => 3,
'PipelineUpdateWorker' => 3,
'PostReceive' => 3, 'PostReceive' => 3,
'ProcessCommitWorker' => 3, 'ProcessCommitWorker' => 3,
'ProjectCacheWorker' => 3, 'ProjectCacheWorker' => 3,
......
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