Skip to content

Commit

Permalink
Fix task rate limiting (#3137)
Browse files Browse the repository at this point in the history
  • Loading branch information
yycptt authored and alexshtin committed Jul 29, 2022
1 parent 4d7772d commit 84149d3
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion service/history/queues/priority_assigner.go
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ func (a *priorityAssignerImpl) Assign(executable Executable) error {
return nil
}

ratelimiter := a.getOrCreateRateLimiter(executable.GetNamespaceID())
ratelimiter := a.getOrCreateRateLimiter(namespaceName)
if !ratelimiter.Allow() {
executable.SetPriority(tasks.PriorityMedium)

Expand Down

0 comments on commit 84149d3

Please sign in to comment.