diff options
| -rw-r--r-- | app/models/ci/build_trace_chunk.rb | 2 | ||||
| -rw-r--r-- | app/workers/all_queues.yml | 2 | ||||
| -rw-r--r-- | app/workers/build_trace_chunk_flush_to_db_worker.rb (renamed from app/workers/build_trace_swap_chunk_worker.rb) | 2 | ||||
| -rw-r--r-- | spec/models/ci/build_trace_chunk_spec.rb | 4 |
4 files changed, 5 insertions, 5 deletions
diff --git a/app/models/ci/build_trace_chunk.rb b/app/models/ci/build_trace_chunk.rb index b9b84104b33..4c1449cbb70 100644 --- a/app/models/ci/build_trace_chunk.rb +++ b/app/models/ci/build_trace_chunk.rb @@ -99,7 +99,7 @@ module Ci def schedule_to_db return if db? - BuildTraceSwapChunkWorker.perform_async(id) + BuildTraceChunkFlushToDBWorker.perform_async(id) end def fullfilled? diff --git a/app/workers/all_queues.yml b/app/workers/all_queues.yml index 44388e7ca0f..0d30971dfd2 100644 --- a/app/workers/all_queues.yml +++ b/app/workers/all_queues.yml @@ -66,7 +66,7 @@ - pipeline_processing:pipeline_update - pipeline_processing:stage_update - pipeline_processing:update_head_pipeline_for_merge_request -- pipeline_processing:build_trace_swap_chunk +- pipeline_processing:build_trace_chunk_flush_to_db - repository_check:repository_check_clear - repository_check:repository_check_single_repository diff --git a/app/workers/build_trace_swap_chunk_worker.rb b/app/workers/build_trace_chunk_flush_to_db_worker.rb index 1392b9d34e1..447dfc4d229 100644 --- a/app/workers/build_trace_swap_chunk_worker.rb +++ b/app/workers/build_trace_chunk_flush_to_db_worker.rb @@ -1,4 +1,4 @@ -class BuildTraceSwapChunkWorker +class BuildTraceChunkFlushToDBWorker include ApplicationWorker include PipelineQueue diff --git a/spec/models/ci/build_trace_chunk_spec.rb b/spec/models/ci/build_trace_chunk_spec.rb index 99fbba4afa9..4a58971a441 100644 --- a/spec/models/ci/build_trace_chunk_spec.rb +++ b/spec/models/ci/build_trace_chunk_spec.rb @@ -75,7 +75,7 @@ describe Ci::BuildTraceChunk, :clean_gitlab_redis_shared_state do let(:value) { 'a' * described_class::CHUNK_SIZE } it 'schedules stashing data' do - expect(BuildTraceSwapChunkWorker).to receive(:perform_async).once + expect(BuildTraceChunkFlushToDBWorker).to receive(:perform_async).once subject end @@ -112,7 +112,7 @@ describe Ci::BuildTraceChunk, :clean_gitlab_redis_shared_state do context 'when fullfilled chunk size' do it 'does not schedule stashing data' do - expect(BuildTraceSwapChunkWorker).not_to receive(:perform_async) + expect(BuildTraceChunkFlushToDBWorker).not_to receive(:perform_async) subject end |