Remove unused BuildProcessWorker
We migrated all logic to `PipelineProcessWorker` and this worker become redundant.
This commit is contained in:
parent
8ae75677a3
commit
1438119df4
3 changed files with 0 additions and 43 deletions
|
@ -88,7 +88,6 @@
|
||||||
- pipeline_processing:ci_build_prepare
|
- pipeline_processing:ci_build_prepare
|
||||||
- pipeline_processing:build_queue
|
- pipeline_processing:build_queue
|
||||||
- pipeline_processing:build_success
|
- pipeline_processing:build_success
|
||||||
- pipeline_processing:build_process
|
|
||||||
- pipeline_processing:pipeline_process
|
- pipeline_processing:pipeline_process
|
||||||
- pipeline_processing:pipeline_success
|
- pipeline_processing:pipeline_success
|
||||||
- pipeline_processing:pipeline_update
|
- pipeline_processing:pipeline_update
|
||||||
|
|
|
@ -1,16 +0,0 @@
|
||||||
# frozen_string_literal: true
|
|
||||||
|
|
||||||
class BuildProcessWorker
|
|
||||||
include ApplicationWorker
|
|
||||||
include PipelineQueue
|
|
||||||
|
|
||||||
queue_namespace :pipeline_processing
|
|
||||||
|
|
||||||
# rubocop: disable CodeReuse/ActiveRecord
|
|
||||||
def perform(build_id)
|
|
||||||
CommitStatus.find_by(id: build_id).try do |build|
|
|
||||||
build.pipeline.process!([build_id])
|
|
||||||
end
|
|
||||||
end
|
|
||||||
# rubocop: enable CodeReuse/ActiveRecord
|
|
||||||
end
|
|
|
@ -1,26 +0,0 @@
|
||||||
# frozen_string_literal: true
|
|
||||||
|
|
||||||
require 'spec_helper'
|
|
||||||
|
|
||||||
describe BuildProcessWorker do
|
|
||||||
describe '#perform' do
|
|
||||||
context 'when build exists' do
|
|
||||||
let(:pipeline) { create(:ci_pipeline) }
|
|
||||||
let(:build) { create(:ci_build, pipeline: pipeline) }
|
|
||||||
|
|
||||||
it 'processes build' do
|
|
||||||
expect_any_instance_of(Ci::Pipeline).to receive(:process!)
|
|
||||||
.with([build.id])
|
|
||||||
|
|
||||||
described_class.new.perform(build.id)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
context 'when build does not exist' do
|
|
||||||
it 'does not raise exception' do
|
|
||||||
expect { described_class.new.perform(123) }
|
|
||||||
.not_to raise_error
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
Loading…
Reference in a new issue