Sha256: 9a948319ada50a0bd144b0bb640fd83d89498d4ebc51360182dd6d703cdcfbcc
Contents?: true
Size: 426 Bytes
Versions: 1
Compression:
Stored size: 426 Bytes
Contents
class QueueWorkerWithFilterProc < QueueWorker # slightly contrived example of munging args to the # worker and removing a random bit. sidekiq_options unique: true, unique_lock: :until_timeout, unique_args: (lambda do |*args| options = args.extract_options! options.delete(:random) [args, options] end) end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
sidekiq-unique-jobs-4.0.0 | spec/workers/queue_worker_with_filter_proc.rb |