Keep multi cursor default reader always running (#3626)

temporalio · Nov 19, 2022 · 9541374 · 9541374
1 parent 91a67f4
commit 9541374
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/service/history/queues/queue_base.go b/service/history/queues/queue_base.go
@@ -356,7 +356,9 @@ func (p *queueBase) checkpoint() {
 		scopes := reader.Scopes()
 
 		if len(scopes) == 0 {
-			p.readerGroup.RemoveReader(readerID)
+			if readerID != DefaultReaderId {
+				p.readerGroup.RemoveReader(readerID)
+			}
 			continue
 		}