Commit f8f62ea5 authored by Shinya Maeda's avatar Shinya Maeda

Rename to SwapTraceChunkWorker from StashTraceChunkWorker

parent 242b4afa
...@@ -84,7 +84,7 @@ module Ci ...@@ -84,7 +84,7 @@ module Ci
def schedule_to_db def schedule_to_db
return if db? return if db?
StashTraceChunkWorker.perform_async(id) SwapTraceChunkWorker.perform_async(id)
end end
def fullfilled? def fullfilled?
......
...@@ -62,7 +62,7 @@ ...@@ -62,7 +62,7 @@
- pipeline_processing:pipeline_update - pipeline_processing:pipeline_update
- pipeline_processing:stage_update - pipeline_processing:stage_update
- pipeline_processing:update_head_pipeline_for_merge_request - pipeline_processing:update_head_pipeline_for_merge_request
- pipeline_processing:stash_trace_chunk - pipeline_processing:swap_trace_chunk
- repository_check:repository_check_clear - repository_check:repository_check_clear
- repository_check:repository_check_single_repository - repository_check:repository_check_single_repository
......
class StashTraceChunkWorker class SwapTraceChunkWorker
include ApplicationWorker include ApplicationWorker
include PipelineQueue include PipelineQueue
......
This source diff could not be displayed because it is too large. You can view the blob instead.
...@@ -70,7 +70,7 @@ describe Ci::JobTraceChunk, :clean_gitlab_redis_shared_state do ...@@ -70,7 +70,7 @@ describe Ci::JobTraceChunk, :clean_gitlab_redis_shared_state do
let(:value) { 'a' * described_class::CHUNK_SIZE } let(:value) { 'a' * described_class::CHUNK_SIZE }
it 'schedules stashing data' do it 'schedules stashing data' do
expect(StashTraceChunkWorker).to receive(:perform_async).once expect(SwapTraceChunkWorker).to receive(:perform_async).once
subject subject
end end
...@@ -107,7 +107,7 @@ describe Ci::JobTraceChunk, :clean_gitlab_redis_shared_state do ...@@ -107,7 +107,7 @@ describe Ci::JobTraceChunk, :clean_gitlab_redis_shared_state do
context 'when fullfilled chunk size' do context 'when fullfilled chunk size' do
it 'does not schedule stashing data' do it 'does not schedule stashing data' do
expect(StashTraceChunkWorker).not_to receive(:perform_async) expect(SwapTraceChunkWorker).not_to receive(:perform_async)
subject subject
end end
......
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