diff --git a/cmd/bsky-activity/main.go b/cmd/bsky-activity/main.go
index 963642e..344b973 100644
--- a/cmd/bsky-activity/main.go
+++ b/cmd/bsky-activity/main.go
@@ -94,11 +94,10 @@ func handler(ctx context.Context, queue *Queue) {
 	pipe := rdb.Pipeline()
 	var eventCount int
 
-eventLoop:
 	for {
 		select {
 		case <-ctx.Done():
-			break eventLoop
+			return
 		default:
 		}