From 19c055cae792facb5e441419f8fe03e8e975cc87 Mon Sep 17 00:00:00 2001
From: Ilya Ozherelyev <ilya.ozherelyev@uber.com>
Date: Mon, 11 Nov 2024 18:53:37 +0100
Subject: [PATCH] remove WG.Add

---
 internal/internal_worker_base.go | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/internal/internal_worker_base.go b/internal/internal_worker_base.go
index ae185a4f6..244e502fb 100644
--- a/internal/internal_worker_base.go
+++ b/internal/internal_worker_base.go
@@ -214,11 +214,7 @@ func (bw *baseWorker) Start() {
 
 	bw.shutdownWG.Add(1)
 	go bw.runTaskDispatcher()
-
-	// We want the emit function run once per host instead of run once per worker
-	// since the emit function is host level metric.
-	bw.shutdownWG.Add(1)
-
+	
 	bw.isWorkerStarted = true
 	traceLog(func() {
 		bw.logger.Info("Started Worker",