Rename BuildTraceSwapChunkWorker to BuildTraceChunkFlushToDBWorker

This commit is contained in:
Shinya Maeda 2018-05-02 16:52:54 +09:00
parent abe87373ab
commit 950df8babf
4 changed files with 5 additions and 5 deletions

View File

@ -99,7 +99,7 @@ module Ci
def schedule_to_db
return if db?
BuildTraceSwapChunkWorker.perform_async(id)
BuildTraceChunkFlushToDBWorker.perform_async(id)
end
def fullfilled?

View File

@ -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

View File

@ -1,4 +1,4 @@
class BuildTraceSwapChunkWorker
class BuildTraceChunkFlushToDBWorker
include ApplicationWorker
include PipelineQueue

View File

@ -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