diff --git a/internal/firehose/stream.go b/internal/firehose/stream.go
index 9cfda74..7ae5b8d 100644
--- a/internal/firehose/stream.go
+++ b/internal/firehose/stream.go
@@ -139,22 +139,14 @@ func (fh *FirehoseListener) SubscribeFirehose() {
 		},
 	}
 	scheduler := sequential.NewScheduler("stream", rsc.EventHandler)
-	maxRetries := 5
-	delay := 10 * time.Second
-	currentRetry := 0
-	for currentRetry < maxRetries {
-		fh.logger.Info("trying to connect", "try", currentRetry, "maxRetries", maxRetries)
-		con, _, err := websocket.DefaultDialer.Dial(uri, http.Header{})
-		if err != nil {
-			fh.logger.Info("failed to establish connection", "err", err.Error())
-			time.Sleep(delay * time.Duration(currentRetry))
-			continue
-		}
-		err = events.HandleRepoStream(ctx, con, scheduler, fh.logger)
-		if err != nil {
-			fh.logger.Error("handling repo stream", "err", err.Error())
-			time.Sleep(delay * time.Duration(currentRetry))
-		}
+	con, _, err := websocket.DefaultDialer.Dial(uri, http.Header{})
+	if err != nil {
+		fh.logger.Info("failed to establish connection", "err", err.Error())
+		return
+	}
+	err = events.HandleRepoStream(ctx, con, scheduler, fh.logger)
+	if err != nil {
+		fh.logger.Error("handling repo stream", "err", err.Error())
 	}
 }