blob: 443cb6c085572ce7ea4f6344cffbc5b79f6a87fa (
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 WebHooks
class LogExecutionWorker
include ApplicationWorker
data_consistency :always
feature_category :webhooks
urgency :low
sidekiq_options retry: 3
loggable_arguments 0, 2, 3
idempotent!
# This worker accepts an extra argument. This enables us to
# treat this worker as idempotent. Currently this is set to
# the Job ID (jid) of the parent worker.
def perform(hook_id, log_data, response_category, _unique_by)
hook = WebHook.find_by_id(hook_id)
return unless hook # hook has been deleted before we could run.
::WebHooks::LogExecutionService
.new(hook: hook, log_data: log_data, response_category: response_category.to_sym)
.execute
end
end
end
|
