remove WG.Add

cadence-workflow · Nov 11, 2024 · 19c055c · 19c055c
1 parent e3be752
commit 19c055c
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",