1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
# frozen_string_literal: true
module Namespaces
class ProcessOutdatedNamespaceDescendantsCronWorker
BATCH_SIZE = 50
include ApplicationWorker
include LoopWithRuntimeLimit
MAX_RUNTIME = 45.seconds
data_consistency :always
# rubocop:disable Scalability/CronWorkerContext -- This worker does not perform work scoped to a context
include CronjobQueue
# rubocop:enable Scalability/CronWorkerContext
feature_category :groups_and_projects
idempotent!
def perform
processed_namespaces = 0
loop_with_runtime_limit(MAX_RUNTIME) do |runtime_limiter|
namespace_ids = Namespaces::Descendants.load_outdated_batch(BATCH_SIZE)
break if namespace_ids.empty?
namespace_ids.each do |namespace_id|
Namespaces::UpdateDenormalizedDescendantsService
.new(namespace_id: namespace_id)
.execute
processed_namespaces += 1
break if runtime_limiter.over_time?
end
end
log_extra_metadata_on_done(:result, { processed_namespaces: processed_namespaces })
end
end
end
|
