blob: 280d987fa77a70f05622d071758874ab7cce7a42 (
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 :integrations
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
|
