use keyword argument for `delayed` flag
parent
98339c8fb3
commit
04d55aab4a
|
@ -6,7 +6,7 @@ class DistributionWorker
|
|||
def perform(status_id, delayed = false)
|
||||
RedisLock.acquire(redis: Redis.current, key: "distribute:#{status_id}") do |lock|
|
||||
if lock.acquired?
|
||||
FanOutOnWriteService.new.call(Status.find(status_id), delayed)
|
||||
FanOutOnWriteService.new.call(Status.find(status_id), delayed: delayed)
|
||||
else
|
||||
raise Mastodon::RaceConditionError
|
||||
end
|
||||
|
|
Loading…
Reference in New Issue