diff options
| -rw-r--r-- | app/models/ci/job_trace_chunk.rb | 2 | ||||
| -rw-r--r-- | app/workers/all_queues.yml | 2 | ||||
| -rw-r--r-- | app/workers/build_trace_swap_chunk_worker.rb (renamed from app/workers/swap_trace_chunk_worker.rb) | 2 | ||||
| -rw-r--r-- | spec/models/ci/job_trace_chunk_spec.rb | 4 |
4 files changed, 5 insertions, 5 deletions
diff --git a/app/models/ci/job_trace_chunk.rb b/app/models/ci/job_trace_chunk.rb index aeab4d0c87c..47302265fb7 100644 --- a/app/models/ci/job_trace_chunk.rb +++ b/app/models/ci/job_trace_chunk.rb @@ -92,7 +92,7 @@ module Ci def schedule_to_db return if db? - SwapTraceChunkWorker.perform_async(id) + BuildTraceSwapChunkWorker.perform_async(id) end def fullfilled? diff --git a/app/workers/all_queues.yml b/app/workers/all_queues.yml index 571a9455325..e02de6a0830 100644 --- a/app/workers/all_queues.yml +++ b/app/workers/all_queues.yml @@ -65,7 +65,7 @@ - pipeline_processing:pipeline_update - pipeline_processing:stage_update - pipeline_processing:update_head_pipeline_for_merge_request -- pipeline_processing:swap_trace_chunk +- pipeline_processing:build_trace_swap_chunk - repository_check:repository_check_clear - repository_check:repository_check_single_repository diff --git a/app/workers/swap_trace_chunk_worker.rb b/app/workers/build_trace_swap_chunk_worker.rb index 6b30cfa2a48..29b7cd4f808 100644 --- a/app/workers/swap_trace_chunk_worker.rb +++ b/app/workers/build_trace_swap_chunk_worker.rb @@ -1,4 +1,4 @@ -class SwapTraceChunkWorker +class BuildTraceSwapChunkWorker include ApplicationWorker include PipelineQueue diff --git a/spec/models/ci/job_trace_chunk_spec.rb b/spec/models/ci/job_trace_chunk_spec.rb index eb240de188f..b01dfd097e6 100644 --- a/spec/models/ci/job_trace_chunk_spec.rb +++ b/spec/models/ci/job_trace_chunk_spec.rb @@ -71,7 +71,7 @@ describe Ci::JobTraceChunk, :clean_gitlab_redis_shared_state do let(:value) { 'a' * described_class::CHUNK_SIZE } it 'schedules stashing data' do - expect(SwapTraceChunkWorker).to receive(:perform_async).once + expect(BuildTraceSwapChunkWorker).to receive(:perform_async).once subject end @@ -108,7 +108,7 @@ describe Ci::JobTraceChunk, :clean_gitlab_redis_shared_state do context 'when fullfilled chunk size' do it 'does not schedule stashing data' do - expect(SwapTraceChunkWorker).not_to receive(:perform_async) + expect(BuildTraceSwapChunkWorker).not_to receive(:perform_async) subject end |