diff --git a/pkg/frontend/v1/frontend.go b/pkg/frontend/v1/frontend.go index 6bd37274c5c..9eae59255b9 100644 --- a/pkg/frontend/v1/frontend.go +++ b/pkg/frontend/v1/frontend.go @@ -22,7 +22,7 @@ import ( "github.com/cortexproject/cortex/pkg/tenant" "github.com/cortexproject/cortex/pkg/util" "github.com/cortexproject/cortex/pkg/util/httpgrpcutil" - "github.com/cortexproject/cortex/pkg/util/query" + util_query "github.com/cortexproject/cortex/pkg/util/query" "github.com/cortexproject/cortex/pkg/util/services" "github.com/cortexproject/cortex/pkg/util/validation" ) @@ -347,7 +347,7 @@ func (f *Frontend) queueRequest(ctx context.Context, req *request) error { now := time.Now() req.enqueueTime = now req.queueSpan, _ = opentracing.StartSpanFromContext(ctx, "queued") - req.isHighPriority = query.IsHighPriority() + req.isHighPriority = util_query.IsHighPriority() // aggregate the max queriers limit in the case of a multi tenant query maxQueriers := validation.SmallestPositiveNonZeroFloat64PerTenant(tenantIDs, f.limits.MaxQueriersPerUser) diff --git a/pkg/frontend/v2/frontend.go b/pkg/frontend/v2/frontend.go index 202c2d3042c..e01b9562e87 100644 --- a/pkg/frontend/v2/frontend.go +++ b/pkg/frontend/v2/frontend.go @@ -26,7 +26,7 @@ import ( "github.com/cortexproject/cortex/pkg/util/grpcclient" "github.com/cortexproject/cortex/pkg/util/httpgrpcutil" util_log "github.com/cortexproject/cortex/pkg/util/log" - "github.com/cortexproject/cortex/pkg/util/query" + util_query "github.com/cortexproject/cortex/pkg/util/query" "github.com/cortexproject/cortex/pkg/util/services" ) @@ -196,7 +196,7 @@ func (f *Frontend) RoundTripGRPC(ctx context.Context, req *httpgrpc.HTTPRequest) request: req, userID: userID, statsEnabled: stats.IsEnabled(ctx), - isHighPriority: query.IsHighPriority(), + isHighPriority: util_query.IsHighPriority(), cancel: cancel,