Class: SidekiqUniqueJobs::Lock::UntilExecuting
- Defined in:
- lib/sidekiq_unique_jobs/lock/until_executing.rb
Overview
Locks jobs until #execute starts
-
Locks on perform_in or perform_async
-
Unlocks before yielding to the worker’s perform method
Instance Method Summary collapse
-
#execute { ... } ⇒ Object
Executes in the Sidekiq server process.
-
#lock ⇒ String?
Locks a sidekiq job.
Methods inherited from BaseLock
#initialize, #locksmith, validate_options
Methods included from Reflectable
Methods included from SidekiqUniqueJobs::Logging
#build_message, included, #log_debug, #log_error, #log_fatal, #log_info, #log_warn, #logger, #logging_context, #with_configured_loggers_context, #with_logging_context
Constructor Details
This class inherits a constructor from SidekiqUniqueJobs::Lock::BaseLock
Instance Method Details
#execute { ... } ⇒ Object
Executes in the Sidekiq server process
27 28 29 30 |
# File 'lib/sidekiq_unique_jobs/lock/until_executing.rb', line 27 def execute callback_safely if locksmith.unlock yield end |
#lock ⇒ String?
Note:
Will call a conflict strategy if lock can’t be achieved.
Locks a sidekiq job
18 19 20 21 22 23 |
# File 'lib/sidekiq_unique_jobs/lock/until_executing.rb', line 18 def lock return lock_failed unless (job_id = locksmith.lock) return yield job_id if block_given? job_id end |