From 57b57e8cadaeca4047461e29e2622a43378fbbd1 Mon Sep 17 00:00:00 2001 From: Yi Jin Date: Tue, 9 Apr 2024 17:56:54 -0700 Subject: [PATCH] fix CLI flags not pass into the receive handler Signed-off-by: Yi Jin --- cmd/thanos/receive.go | 2 ++ pkg/receive/handler.go | 1 + 2 files changed, 3 insertions(+) diff --git a/cmd/thanos/receive.go b/cmd/thanos/receive.go index 031b82abc62..cd890ce71d1 100644 --- a/cmd/thanos/receive.go +++ b/cmd/thanos/receive.go @@ -255,6 +255,8 @@ func runReceive( MaxBackoff: time.Duration(*conf.maxBackoff), TSDBStats: dbs, Limiter: limiter, + + AsyncForwardWorkerCount: conf.asyncForwardWorkerCount, }) grpcProbe := prober.NewGRPC() diff --git a/pkg/receive/handler.go b/pkg/receive/handler.go index ec53f35650a..8e908487071 100644 --- a/pkg/receive/handler.go +++ b/pkg/receive/handler.go @@ -142,6 +142,7 @@ func NewHandler(logger log.Logger, o *Options) *Handler { if workers == 0 { workers = 1 } + level.Info(logger).Log("msg", "Starting receive handler with async forward workers", "workers", workers) h := &Handler{ logger: logger,