Prioritize worker pool shutdown (#3795)

temporalio · Jan 10, 2023 · bb4ec7f · bb4ec7f
1 parent ea893d1
commit bb4ec7f
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/common/tasks/fifo_scheduler.go b/common/tasks/fifo_scheduler.go
@@ -206,6 +206,12 @@ func (f *FIFOScheduler[T]) processTask(
 			return
 		}
 
+		select {
+		case <-shutdownCh:
+			return
+		default:
+		}
+
 		select {
 		case task := <-f.tasksChan:
 			f.executeTask(task)