summaryrefslogtreecommitdiff
path: root/app/workers/ci
diff options
context:
space:
mode:
authorShinya Maeda <shinya@gitlab.com>2018-05-04 17:02:08 +0900
committerShinya Maeda <shinya@gitlab.com>2018-05-04 17:02:08 +0900
commit812dd06d512ab7774b375ce45aa9235aafc99911 (patch)
tree34cc187b9a70ad95967dff67f3efa397424b9aee /app/workers/ci
parent47c8e06cefb7396c6f08b9908bd34dd21c8d08b0 (diff)
downloadgitlab-ce-812dd06d512ab7774b375ce45aa9235aafc99911.tar.gz
Introduce Redis helpers. Rename BuildTraceChunkFlushToDbWorker to Ci::BuildTraceChunkFlushWorker.
Diffstat (limited to 'app/workers/ci')
-rw-r--r--app/workers/ci/build_trace_chunk_flush_worker.rb13
1 files changed, 13 insertions, 0 deletions
diff --git a/app/workers/ci/build_trace_chunk_flush_worker.rb b/app/workers/ci/build_trace_chunk_flush_worker.rb
new file mode 100644
index 00000000000..b8f8be29c7b
--- /dev/null
+++ b/app/workers/ci/build_trace_chunk_flush_worker.rb
@@ -0,0 +1,13 @@
+module Ci
+ class BuildTraceChunkFlushWorker
+ include ApplicationWorker
+
+ queue_namespace :pipeline_processing
+
+ def perform(build_trace_chunk_id)
+ ::Ci::BuildTraceChunk.find_by(id: build_trace_chunk_id).try do |build_trace_chunk|
+ build_trace_chunk.use_database!
+ end
+ end
+ end
+end