diff --git a/pkg/pipe/arbiter.go b/pkg/pipe/arbiter.go
index a58615a..e6f8f41 100644
--- a/pkg/pipe/arbiter.go
+++ b/pkg/pipe/arbiter.go
@@ -54,6 +54,7 @@ func Arbiter(
 	db redb.RedisDB,
 	forward Forward[string],
 ) {
+	log.Println("Arbiter: ready")
 	defer log.Println("Arbiter: shut down")
 
 	ticker := time.NewTicker(config.PingWait)
diff --git a/pkg/pipe/fetcher.go b/pkg/pipe/fetcher.go
index a87d1da..6434b35 100644
--- a/pkg/pipe/fetcher.go
+++ b/pkg/pipe/fetcher.go
@@ -46,6 +46,7 @@ func Fetcher(
 	pubkeys <-chan string,
 	forward Forward[*nostr.Event],
 ) {
+	log.Println("Fetcher: ready")
 	defer log.Println("Fetcher: shut down")
 
 	batch := make([]string, 0, config.Batch)
@@ -146,7 +147,7 @@ func FetcherDB(
 	pubkeys <-chan string,
 	forward Forward[*nostr.Event],
 ) {
-
+	log.Println("FetcherDB: ready")
 	defer log.Println("FetcherDB: shut down")
 
 	batch := make([]string, 0, config.Batch)
diff --git a/pkg/pipe/recorder.go b/pkg/pipe/recorder.go
index f956df9..0562d6f 100644
--- a/pkg/pipe/recorder.go
+++ b/pkg/pipe/recorder.go
@@ -17,6 +17,7 @@ func Recorder(
 	events <-chan *nostr.Event,
 	forward Forward[*nostr.Event],
 ) {
+	log.Println("Recorder: ready")
 	defer log.Println("Recorder: shut down")
 	timer := midnightTimer()
 
@@ -45,6 +46,7 @@ func Recorder(
 				log.Printf("Recorder: %v", err)
 			}
 
+			log.Printf("Recorder: finalized stats for %s", yesterday)
 			timer = midnightTimer()
 		}
 	}