blob: 112badd08b53f9c9d42170ff8fa5c1f609e6d534 (
plain)
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
|
# frozen_string_literal: true
module Namespaces
# This worker can be called multiple times at the same time but only one of them can
# process events at a time. This is ensured by `try_obtain_lease` in `Ci::ProcessSyncEventsService`.
# `until_executing` here is to reduce redundant worker enqueuing.
class ProcessSyncEventsWorker
include ApplicationWorker
data_consistency :always
feature_category :cell
urgency :high
idempotent!
deduplicate :until_executed, if_deduplicated: :reschedule_once
def perform
results = ::Ci::ProcessSyncEventsService.new(
::Namespaces::SyncEvent, ::Ci::NamespaceMirror
).execute
results.each do |key, value|
log_extra_metadata_on_done(key, value)
end
end
end
end
|
