app/workers/click_house/events_sync_worker.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

# frozen_string_literal: true

module ClickHouse
  class EventsSyncWorker
    include ApplicationWorker
    include ClickHouseWorker

    idempotent!
    queue_namespace :cronjob
    data_consistency :delayed
    worker_has_external_dependencies! # the worker interacts with a ClickHouse database
    feature_category :value_stream_management

    def perform
      result = ::ClickHouse::SyncStrategies::EventSyncStrategy.new.execute
      log_extra_metadata_on_done(:result, result)
    end
  end
end