Commit 446086f1 authored by Shinya Maeda's avatar Shinya Maeda

Add sidekiq worker for writing operation

parent 54aec65e
...@@ -83,7 +83,7 @@ module Ci ...@@ -83,7 +83,7 @@ module Ci
def schedule_to_db def schedule_to_db
return if db? return if db?
self.use_database! StashTraceChunkWorker.perform_async(id)
end end
def fullfilled? def fullfilled?
......
...@@ -62,6 +62,7 @@ ...@@ -62,6 +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
- repository_check:repository_check_clear - repository_check:repository_check_clear
- repository_check:repository_check_single_repository - repository_check:repository_check_single_repository
......
class StashTraceChunkWorker
include ApplicationWorker
include PipelineQueue
queue_namespace :pipeline_processing
def perform(job_trace_chunk_id)
Ci::JobTraceChunk.find_by(id: job_trace_chunk_id).try do |job_trace_chunk|
job_trace_chunk.use_database!
end
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