diff --git a/cmd/crawl/main.go b/cmd/crawl/main.go
index 4fc272a..6f90ffd 100644
--- a/cmd/crawl/main.go
+++ b/cmd/crawl/main.go
@@ -85,6 +85,7 @@ func main() {
 		defer producers.Done()
 		gate := pipe.NewExistenceGate(db)
 		pipe.Firehose(ctx, config.Firehose, gate, pipe.Send(recorderQueue))
+		close(recorderQueue)
 	}()
 
 	go func() {
@@ -100,7 +101,7 @@ func main() {
 	go func() {
 		defer producers.Done()
 		pipe.Arbiter(ctx, config.Arbiter, db, pipe.Send(fetcherQueue))
-		close(fetcherQueue) // Arbiter is the only pubkey producer
+		close(fetcherQueue)
 	}()
 
 	consumers.Add(1)
diff --git a/cmd/sync/main.go b/cmd/sync/main.go
index a16ba2c..8264644 100644
--- a/cmd/sync/main.go
+++ b/cmd/sync/main.go
@@ -81,13 +81,13 @@ func main() {
 	go func() {
 		defer wg.Done()
 		pipe.FetcherDB(ctx, config.Fetcher, fetcherQueue, store, pipe.Send(grapherQueue))
-		close(grapherQueue) // FetcherDB is the only event producer
+		close(grapherQueue)
 	}()
 
 	go func() {
 		defer wg.Done()
 		pipe.Arbiter(ctx, config.Arbiter, db, pipe.Send(fetcherQueue))
-		close(fetcherQueue) // Arbiter is the only pubkey producer
+		close(fetcherQueue)
 	}()
 
 	go func() {