Stop logging poller errors after stop

Fixes temporalio#882
cretz · Aug 29, 2022 · 60e4e24 · 60e4e24
1 parent 85978da
commit 60e4e24
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/internal/internal_worker_base.go b/internal/internal_worker_base.go
@@ -357,6 +357,13 @@ func (bw *baseWorker) pollTask() {
 }
 
 func (bw *baseWorker) logPollTaskError(err error) {
+	// We do not want to log any errors after we were explicitly stopped
+	select {
+	case <-bw.stopCh:
+		return
+	default:
+	}
+
 	bw.lastPollTaskErrLock.Lock()
 	defer bw.lastPollTaskErrLock.Unlock()
 	// No error means reset the message and time