Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitlab-foss.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'app/workers/cluster_update_app_worker.rb')
-rw-r--r--app/workers/cluster_update_app_worker.rb36
1 files changed, 2 insertions, 34 deletions
diff --git a/app/workers/cluster_update_app_worker.rb b/app/workers/cluster_update_app_worker.rb
index 97fdec02ba4..7d997c0a293 100644
--- a/app/workers/cluster_update_app_worker.rb
+++ b/app/workers/cluster_update_app_worker.rb
@@ -1,6 +1,7 @@
# frozen_string_literal: true
# Deprecated, to be removed in %14.0 as part of https://gitlab.com/groups/gitlab-org/-/epics/4280
+# Also see https://gitlab.com/gitlab-org/gitlab/-/issues/366573
class ClusterUpdateAppWorker # rubocop:disable Scalability/IdempotentWorker
UpdateAlreadyInProgressError = Class.new(StandardError)
@@ -16,38 +17,5 @@ class ClusterUpdateAppWorker # rubocop:disable Scalability/IdempotentWorker
LEASE_TIMEOUT = 10.minutes.to_i
- def perform(app_name, app_id, project_id, scheduled_time)
- @app_id = app_id
-
- try_obtain_lease do
- execute(app_name, app_id, project_id, scheduled_time)
- end
- end
-
- private
-
- def execute(app_name, app_id, project_id, scheduled_time)
- project = Project.find_by_id(project_id)
- return unless project
-
- find_application(app_name, app_id) do |app|
- update_prometheus(app, scheduled_time, project)
- end
- end
-
- def update_prometheus(app, scheduled_time, project)
- return unless app.managed_prometheus?
- return if app.updated_since?(scheduled_time)
- return if app.update_in_progress?
-
- Clusters::Applications::PrometheusUpdateService.new(app, project).execute
- end
-
- def lease_key
- @lease_key ||= "#{self.class.name.underscore}-#{@app_id}"
- end
-
- def lease_timeout
- LEASE_TIMEOUT
- end
+ def perform(app_name, app_id, project_id, scheduled_time); end
end