Temporarily add a paranoid check on LineMerger.Err()

#40
brawer · May 17, 2024 · 60d05f9 · 60d05f9
1 parent 7716965
commit 60d05f9
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/cmd/qrank-builder/itemsignals.go b/cmd/qrank-builder/itemsignals.go
@@ -194,6 +194,10 @@ func buildItemSignals(ctx context.Context, pageviews []string, sites *map[string
 		var numOrderErrors int64
 		var numLines int64
 		for merg.Advance() {
+			if err := merg.Err(); err != nil {
+				logger.Printf("LineMerger.Err() is non-nil but LineMerger.Advance() was true; err=%v", err)
+				break
+			}
 			numLines += 1
 			line := merg.Line()
 			if lastLine >= line {