Add some logging statements

#40
brawer · May 14, 2024 · 841e457 · 841e457
1 parent b037fdb
commit 841e457
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/cmd/qrank-builder/itemsignals.go b/cmd/qrank-builder/itemsignals.go
@@ -195,6 +195,7 @@ func buildItemSignals(ctx context.Context, pageviews []string, sites *map[string
 		for merger.Advance() {
 			if err := joiner.Process(merger.Line()); err != nil {
 				joiner.Close()
+				logger.Printf("ItemSignalsJoiner.Process() failed: %v", err)
 				return err
 			}
 		}
@@ -209,9 +210,14 @@ func buildItemSignals(ctx context.Context, pageviews []string, sites *map[string
 				return groupCtx.Err()
 			case s, more := <-outChan:
 				if !more {
-					return writer.Close()
+					err := writer.Close()
+					if err != nil {
+						logger.Printf("ItemSignalsWriter.Close() failed: %v", err)
+					}
+					return err
 				}
 				if err := writer.Write(s.(ItemSignals)); err != nil {
+					logger.Printf("ItemSignalsWriter.Write() failed: %v", err)
 					return err
 				}
 			}