summaryrefslogtreecommitdiff
path: root/app/workers/environments/auto_delete_cron_worker.rb
diff options
context:
space:
mode:
Diffstat (limited to 'app/workers/environments/auto_delete_cron_worker.rb')
-rw-r--r--app/workers/environments/auto_delete_cron_worker.rb34
1 files changed, 34 insertions, 0 deletions
diff --git a/app/workers/environments/auto_delete_cron_worker.rb b/app/workers/environments/auto_delete_cron_worker.rb
new file mode 100644
index 00000000000..12c08f07d95
--- /dev/null
+++ b/app/workers/environments/auto_delete_cron_worker.rb
@@ -0,0 +1,34 @@
+# frozen_string_literal: true
+
+module Environments
+ class AutoDeleteCronWorker
+ include ApplicationWorker
+ include ::Gitlab::LoopHelpers
+ include CronjobQueue # rubocop:disable Scalability/CronWorkerContext
+
+ data_consistency :always
+ feature_category :continuous_delivery
+ deduplicate :until_executed, including_scheduled: true
+ idempotent!
+
+ LOOP_TIMEOUT = 45.minutes
+ LOOP_LIMIT = 1000
+ BATCH_SIZE = 100
+
+ def perform
+ loop_until(timeout: LOOP_TIMEOUT, limit: LOOP_LIMIT) do
+ destroy_in_batch
+ end
+ end
+
+ private
+
+ def destroy_in_batch
+ environments = Environment.auto_deletable(BATCH_SIZE)
+
+ return false if environments.empty?
+
+ environments.each(&:destroy)
+ end
+ end
+end