feat: re-index on startup if last run > 24 hours ago
Alan Pearce alan@alanpearce.eu
Mon, 24 Mar 2025 17:18:49 +0100
1 files changed, 8 insertions(+), 2 deletions(-)
jump to
M internal/importer/main.go → internal/importer/main.go
@@ -300,7 +300,13 @@ CheckInMargin: 5, Timezone: time.Local.String(), } - nextRun := nextUTCOccurrenceOfTime(imp.config.Importer.UpdateAt) + var nextRun time.Time + if Job.FinishedAt.Before(time.Now().Add(-24 * time.Hour)) { + imp.log.Info("indexing last ran more than 24 hours ago, scheduling immediate update") + nextRun = time.Now() + } else { + nextRun = nextUTCOccurrenceOfTime(imp.config.Importer.UpdateAt) + } SetNextRun(nextRun) for { imp.log.Debug("scheduling next run", "next-run", nextRun) @@ -338,7 +344,7 @@ MonitorSlug: monitorSlug, Status: sentry.CheckInStatusOK, }, monitorConfig) } - nextRun = nextRun.AddDate(0, 0, 1) + nextRun = nextUTCOccurrenceOfTime(imp.config.Importer.UpdateAt) MarkIndexingFinished(nextRun) } })