Fix slice pending task count (#3676)

temporalio · Nov 30, 2022 · f6a340d · f6a340d
1 parent f389611
commit f6a340d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/service/history/queues/slice.go b/service/history/queues/slice.go
@@ -366,7 +366,9 @@ func (s *SliceImpl) SelectTasks(readerID int32, batchSize int) ([]Executable, er
 		return []Executable{}, nil
 	}
 
-	defer s.monitor.SetSlicePendingTaskCount(s, len(s.executableTracker.pendingExecutables))
+	defer func() {
+		s.monitor.SetSlicePendingTaskCount(s, len(s.executableTracker.pendingExecutables))
+	}()
 
 	executables := make([]Executable, 0, batchSize)
 	for len(executables) < batchSize && len(s.iterators) != 0 {