Skip to content

Commit af8ce79

Browse files
committed
Rename concurrency limit spec to limits_concurrency to: limit ...
Thanks to @jorgemanrubia for the suggestion!
1 parent 196116f commit af8ce79

File tree

4 files changed

+5
-5
lines changed

4 files changed

+5
-5
lines changed

lib/active_job/concurrency_controls.rb

+2-2
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,8 @@ module ConcurrencyControls
1414
end
1515

1616
class_methods do
17-
def restrict_concurrency_with(limit: 1, key: DEFAULT_CONCURRENCY_KEY, duration: SolidQueue.default_concurrency_control_period)
18-
self.concurrency_limit = limit
17+
def limits_concurrency(to: 1, key: DEFAULT_CONCURRENCY_KEY, duration: SolidQueue.default_concurrency_control_period)
18+
self.concurrency_limit = to
1919
self.concurrency_key = key
2020
self.concurrency_duration = duration
2121
end
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
11
class SequentialUpdateResultJob < UpdateResultJob
2-
restrict_concurrency_with limit: 1, key: ->(job_result, **) { job_result }
2+
limits_concurrency key: ->(job_result, **) { job_result }
33
end
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
11
class ThrottledUpdateResultJob < UpdateResultJob
2-
restrict_concurrency_with limit: 3, key: ->(job_result, **) { job_result }
2+
limits_concurrency to: 3, key: ->(job_result, **) { job_result }
33
end

test/models/solid_queue/job_test.rb

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
class SolidQueue::JobTest < ActiveSupport::TestCase
44
class NonOverlappingJob < ApplicationJob
5-
restrict_concurrency_with limit: 1, key: ->(job_result, **) { job_result }
5+
limits_concurrency key: ->(job_result, **) { job_result }
66

77
def perform(job_result)
88
end

0 commit comments

Comments
 (0)