diff --git a/x/rate/semaphore.go b/x/rate/semaphore.go index ce00b4b..5a422a5 100644 --- a/x/rate/semaphore.go +++ b/x/rate/semaphore.go @@ -109,6 +109,6 @@ func (s *Semaphore) Close() error { return s.rc.Close() } -func semaphoreKey(name string) string { - return fmt.Sprintf("asynq:sema:%s", name) +func semaphoreKey(scope string) string { + return fmt.Sprintf("asynq:sema:%s", scope) }