diff options
| -rw-r--r-- | app/workers/all_queues.yml | 2 | ||||
| -rw-r--r-- | app/workers/ci/build_trace_chunk_flush_worker.rb | 3 | ||||
| -rw-r--r-- | spec/requests/api/runner_spec.rb | 2 |
3 files changed, 3 insertions, 4 deletions
diff --git a/app/workers/all_queues.yml b/app/workers/all_queues.yml index dc628bb7f50..5d9ec6142d7 100644 --- a/app/workers/all_queues.yml +++ b/app/workers/all_queues.yml @@ -52,6 +52,7 @@ - pipeline_creation:create_pipeline - pipeline_creation:run_pipeline_schedule - pipeline_background:archive_trace +- pipeline_background:ci_build_trace_chunk_flush - pipeline_default:build_coverage - pipeline_default:build_trace_sections - pipeline_default:pipeline_metrics @@ -66,7 +67,6 @@ - pipeline_processing:pipeline_update - pipeline_processing:stage_update - pipeline_processing:update_head_pipeline_for_merge_request -- pipeline_processing:ci_build_trace_chunk_flush - repository_check:repository_check_clear - repository_check:repository_check_single_repository diff --git a/app/workers/ci/build_trace_chunk_flush_worker.rb b/app/workers/ci/build_trace_chunk_flush_worker.rb index b8f8be29c7b..218d6688bd9 100644 --- a/app/workers/ci/build_trace_chunk_flush_worker.rb +++ b/app/workers/ci/build_trace_chunk_flush_worker.rb @@ -1,8 +1,7 @@ module Ci class BuildTraceChunkFlushWorker include ApplicationWorker - - queue_namespace :pipeline_processing + include PipelineBackgroundQueue def perform(build_trace_chunk_id) ::Ci::BuildTraceChunk.find_by(id: build_trace_chunk_id).try do |build_trace_chunk| diff --git a/spec/requests/api/runner_spec.rb b/spec/requests/api/runner_spec.rb index 592256a3acf..70c3529da03 100644 --- a/spec/requests/api/runner_spec.rb +++ b/spec/requests/api/runner_spec.rb @@ -901,7 +901,7 @@ describe API::Runner, :clean_gitlab_redis_shared_state do context 'when we resend full trace' do before do - patch_the_trace('BUILD TRACE appended appended hello') + patch_the_trace('BUILD TRACE appended appended hello', headers.merge({ 'Content-Range' => "0-32" })) end it 'succeeds with updating trace' do |