lib/acidic_job/extensions/sidekiq.rb in acidic_job-1.0.0.pre10 vs lib/acidic_job/extensions/sidekiq.rb in acidic_job-1.0.0.pre11
- old
+ new
@@ -56,13 +56,11 @@
concerning :PerformAcidicly do
class_methods do
def perform_acidicly(*args, **kwargs)
serialized_job = serialize_with_arguments(*args, **kwargs)
- # use either [1] provided key, [2] provided uniqueness constraint, or [3] computed key
- key = if kwargs.key?(:idempotency_key) || kwargs.key?("idempotency_key")
- kwargs[:idempotency_key] || kwargs["idempotency_key"]
- elsif kwargs.key?(:unique_by) || kwargs.key?("unique_by")
+ # use either [1] provided uniqueness constraint or [2] computed key
+ key = if kwargs.key?(:unique_by) || kwargs.key?("unique_by")
unique_by = [kwargs[:unique_by], kwargs["unique_by"]].compact.first
IdempotencyKey.generate(unique_by: unique_by, job_class: name)
else
IdempotencyKey.new(acidic_identifier).value_for(serialized_job)
end