Skip to content

Commit 3e96d0d

Browse files
committed
Fix e2e tests
1 parent eeb32ad commit 3e96d0d

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

cmd/thanos/query.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -567,15 +567,16 @@ func runQuery(
567567
queryableCreator query.QueryableCreator
568568
)
569569
if groupReplicaPartialResponseStrategy {
570-
queryableCreator = query.NewQueryableCreator(
570+
level.Info(logger).Log("msg", "Enabled group-replica partial response strategy")
571+
queryableCreator = query.NewQueryableCreatorWithGroupReplicaPartialResponseStrategy(
571572
logger,
572573
extprom.WrapRegistererWithPrefix("thanos_query_", reg),
573574
proxy,
574575
maxConcurrentSelects,
575576
queryTimeout,
576577
)
577578
} else {
578-
queryableCreator = query.NewQueryableCreatorWithGroupReplicaPartialResponseStrategy(
579+
queryableCreator = query.NewQueryableCreator(
579580
logger,
580581
extprom.WrapRegistererWithPrefix("thanos_query_", reg),
581582
proxy,

pkg/query/querier.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ import (
1010
"time"
1111

1212
"github.com/go-kit/log"
13+
"github.com/go-kit/log/level"
1314
"github.com/opentracing/opentracing-go"
1415
"github.com/pkg/errors"
1516

@@ -204,7 +205,7 @@ func newQuerierInternal(
204205

205206
partialResponseStrategy := storepb.PartialResponseStrategy_ABORT
206207
if groupReplicaPartialResponseStrategy {
207-
logger.Log("msg", "groupReplicaPartialResponseStrategy is enabled")
208+
level.Debug(logger).Log("msg", "Enabled group-replica partial response strategy in newQuerierInternal")
208209
partialResponseStrategy = storepb.PartialResponseStrategy_GROUP_REPLICA
209210
} else if partialResponse {
210211
partialResponseStrategy = storepb.PartialResponseStrategy_WARN

0 commit comments

Comments
 (0)