diff options
Diffstat (limited to 'app/workers')
-rw-r--r-- | app/workers/all_queues.yml | 14 | ||||
-rw-r--r-- | app/workers/ci/daily_report_results_worker.rb | 16 | ||||
-rw-r--r-- | app/workers/pipeline_success_worker.rb | 13 |
3 files changed, 23 insertions, 20 deletions
diff --git a/app/workers/all_queues.yml b/app/workers/all_queues.yml index 28fab10d931..3df86e3314d 100644 --- a/app/workers/all_queues.yml +++ b/app/workers/all_queues.yml @@ -605,6 +605,13 @@ :resource_boundary: :unknown :weight: 1 :idempotent: +- :name: pipeline_background:ci_daily_report_results + :feature_category: :continuous_integration + :has_external_dependencies: + :urgency: :low + :resource_boundary: :unknown + :weight: 1 + :idempotent: true - :name: pipeline_cache:expire_job_cache :feature_category: :continuous_integration :has_external_dependencies: @@ -745,13 +752,6 @@ :resource_boundary: :unknown :weight: 5 :idempotent: -- :name: pipeline_processing:pipeline_success - :feature_category: :continuous_integration - :has_external_dependencies: - :urgency: :high - :resource_boundary: :unknown - :weight: 5 - :idempotent: - :name: pipeline_processing:pipeline_update :feature_category: :continuous_integration :has_external_dependencies: diff --git a/app/workers/ci/daily_report_results_worker.rb b/app/workers/ci/daily_report_results_worker.rb new file mode 100644 index 00000000000..314fd44f86c --- /dev/null +++ b/app/workers/ci/daily_report_results_worker.rb @@ -0,0 +1,16 @@ +# frozen_string_literal: true + +module Ci + class DailyReportResultsWorker + include ApplicationWorker + include PipelineBackgroundQueue + + idempotent! + + def perform(pipeline_id) + Ci::Pipeline.find_by_id(pipeline_id).try do |pipeline| + Ci::DailyReportResultService.new.execute(pipeline) + end + end + end +end diff --git a/app/workers/pipeline_success_worker.rb b/app/workers/pipeline_success_worker.rb deleted file mode 100644 index d84612c52d1..00000000000 --- a/app/workers/pipeline_success_worker.rb +++ /dev/null @@ -1,13 +0,0 @@ -# frozen_string_literal: true - -class PipelineSuccessWorker # rubocop:disable Scalability/IdempotentWorker - include ApplicationWorker - include PipelineQueue - - queue_namespace :pipeline_processing - urgency :high - - def perform(pipeline_id) - # no-op - end -end |