diff --git a/lib/active_job/traffic_control/concurrency.rb b/lib/active_job/traffic_control/concurrency.rb index 894457c..b3e2fe5 100644 --- a/lib/active_job/traffic_control/concurrency.rb +++ b/lib/active_job/traffic_control/concurrency.rb @@ -34,7 +34,7 @@ def concurrency_lock_key(job) if self.class.job_concurrency.present? lock_options = { resources: self.class.job_concurrency[:threshold], - acquisition_lock: self.class.job_concurrency[:wait_timeout], + acquisition_timeout: self.class.job_concurrency[:wait_timeout], stale_lock_expiration: self.class.job_concurrency[:stale_timeout] }