From 8b132ed7f82631de23a63d0cb4ea59f43127a953 Mon Sep 17 00:00:00 2001 From: Jan Eitzinger Date: Wed, 18 Mar 2026 06:47:45 +0100 Subject: [PATCH] fix: Blocking ReceiveNats call Entire-Checkpoint: 38a235c86ceb --- pkg/metricstore/metricstore.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/pkg/metricstore/metricstore.go b/pkg/metricstore/metricstore.go index 83c78ab2..1c475269 100644 --- a/pkg/metricstore/metricstore.go +++ b/pkg/metricstore/metricstore.go @@ -184,10 +184,11 @@ func Init(rawConfig json.RawMessage, metrics map[string]MetricConfig, wg *sync.W shutdownFuncMu.Unlock() if Keys.Subscriptions != nil { - err = ReceiveNats(ms, Keys.NumWorkers, ctx) - if err != nil { - cclog.Fatal(err) - } + wg.Go(func() { + if err := ReceiveNats(ms, Keys.NumWorkers, ctx); err != nil { + cclog.Fatal(err) + } + }) } }