Class: WebHooks::LogExecutionWorker
- Inherits:
-
Object
- Object
- WebHooks::LogExecutionWorker
- Includes:
- ApplicationWorker
- Defined in:
- app/workers/web_hooks/log_execution_worker.rb
Constant Summary
Constants included from ApplicationWorker
ApplicationWorker::LOGGING_EXTRA_KEY, ApplicationWorker::SAFE_PUSH_BULK_LIMIT
Constants included from Gitlab::Loggable
Constants included from WorkerAttributes
WorkerAttributes::DEFAULT_DATA_CONSISTENCY, WorkerAttributes::DEFAULT_DEFER_DELAY, WorkerAttributes::NAMESPACE_WEIGHTS, WorkerAttributes::VALID_DATA_CONSISTENCIES, WorkerAttributes::VALID_RESOURCE_BOUNDARIES, WorkerAttributes::VALID_URGENCIES
Instance Method Summary collapse
-
#perform(hook_id, log_data, response_category, _unique_by) ⇒ Object
This worker accepts an extra argument.
Methods included from Gitlab::Loggable
Methods included from Gitlab::SidekiqVersioning::Worker
Methods included from WorkerContext
Instance Method Details
#perform(hook_id, log_data, response_category, _unique_by) ⇒ Object
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.
18 19 20 21 22 23 24 25 26 |
# File 'app/workers/web_hooks/log_execution_worker.rb', line 18 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 |