From 4f3e160723c583fbf3995b0ceb92e996fdf585eb 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 4ced493c94..1a193d30bd 100644 --- a/cmd/thanos/receive.go +++ b/cmd/thanos/receive.go @@ -256,6 +256,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 4314070a44..208c01b131 100644 --- a/pkg/receive/handler.go +++ b/pkg/receive/handler.go @@ -145,6 +145,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,