Change queue namespace of UpdateHeadPipelineForMergeRequestWorker

This commit is contained in:
Shinya Maeda 2018-03-07 02:43:10 +09:00
parent 10f135cf8a
commit f0dac72979

View file

@ -2,6 +2,8 @@ class UpdateHeadPipelineForMergeRequestWorker
include ApplicationWorker
include PipelineQueue
queue_namespace :pipeline_processing
def perform(merge_request_id)
merge_request = MergeRequest.find(merge_request_id)
pipeline = Ci::Pipeline.where(project: merge_request.source_project, ref: merge_request.source_branch).last