@@ -72,6 +72,7 @@ func Start(db core.DB) {
7272 leaderElector := leaderelection .NewDatabaseLeaderElector (configService )
7373 // only run this function if leader
7474 leaderElector .IfLeader (context .Background (), func () error {
75+ defer time .Sleep (5 * time .Minute ) // wait for 5 minutes before checking again - always - even in case of error
7576 // we only update the vulnerability database each 6 hours.
7677 // thus there is no need to recalculate the risk or anything earlier
7778 slog .Info ("starting background jobs" , "time" , time .Now ())
@@ -85,7 +86,7 @@ func Start(db core.DB) {
8586 slog .Error ("could not delete old asset versions" , "err" , err )
8687 return nil
8788 }
88- if err := markMirrored (configService , "deleteOldAssetVersions" ); err != nil {
89+ if err := markMirrored (configService , "vulndb. deleteOldAssetVersions" ); err != nil {
8990 slog .Error ("could not mark deleteOldAssetVersions as mirrored" , "err" , err )
9091 }
9192 slog .Info ("old asset versions deleted" , "duration" , time .Since (start ))
@@ -198,8 +199,6 @@ func Start(db core.DB) {
198199 slog .Info ("statistics updated" , "duration" , time .Since (start ))
199200 }
200201
201- // wait for 5 minutes before checking again
202- time .Sleep (5 * time .Minute )
203202 return nil
204203 })
205204}
0 commit comments