PIP-2675: Better WorkerPool request hashing.

mailgun · Sep 28, 2023 · d2e07af · d2e07af
1 parent 595eb67
commit d2e07af
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/workers.go b/workers.go
@@ -257,7 +257,7 @@ func (p *WorkerPool) dispatch(worker *Worker) {
 // GetRateLimit sends a GetRateLimit request to worker pool.
 func (p *WorkerPool) GetRateLimit(ctx context.Context, rlRequest *RateLimitReq) (retval *RateLimitResp, reterr error) {
 	// Delegate request to assigned channel based on request key.
-	worker := p.getWorker(rlRequest.UniqueKey)
+	worker := p.getWorker(rlRequest.HashKey())
 	handlerRequest := &request{
 		ctx:     ctx,
 		resp:    make(chan *response, 1),