From 59a10a910e50568f03c707e9a92bfa2755a74201 Mon Sep 17 00:00:00 2001
From: ze0s <43699394+zze0s@users.noreply.github.com>
Date: Tue, 13 Aug 2024 20:46:45 +0200
Subject: [PATCH] fix(feeds): implement staggered start (#1619)

---
 internal/feed/service.go | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/internal/feed/service.go b/internal/feed/service.go
index 561d6d7..f2afba6 100644
--- a/internal/feed/service.go
+++ b/internal/feed/service.go
@@ -308,6 +308,13 @@ func (s *service) start() error {
 		return err
 	}
 
+	if len(feeds) == 0 {
+		s.log.Debug().Msg("found 0 feeds to start")
+		return nil
+	}
+
+	s.log.Debug().Msgf("preparing staggered start of %d feeds", len(feeds))
+
 	for _, feed := range feeds {
 		feed := feed
 
@@ -320,6 +327,9 @@ func (s *service) start() error {
 			s.log.Error().Err(err).Msgf("failed to initialize feed job: %s", feed.Name)
 			continue
 		}
+
+		// add sleep for the next iteration to start staggered which should mitigate sqlite BUSY errors
+		time.Sleep(time.Second * 5)
 	}
 
 	return nil