For example I have a job:
class TestJob
include Sidekiq::Worker
sidekiq_options queue: 'high',
unique: true,
unique_args: ->(args) { [ args.first ] }
def perform(arg)
# do something
end
end
And calling it:
[1] pry(main)> TestJob.perform_async 1
=> "de5ff32394dbcdab2128d5ee"
Then if I go to sidekiq web interface and delete it from the enqueued list before it processed, I can't add a new one with the same argument.
[2] pry(main)> TestJob.perform_async 1
=> nil
I'm pretty sure this is not an expected behaviour. Am I right?
For example I have a job:
And calling it:
Then if I go to sidekiq web interface and delete it from the enqueued list before it processed, I can't add a new one with the same argument.
I'm pretty sure this is not an expected behaviour. Am I right?