remove WG.Add

cadence-workflow · Nov 12, 2024 · 0c10e86 · 0c10e86
1 parent 918a481
commit 0c10e86
Showing 1 changed file with 1 addition and 5 deletions.
diff --git 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",