Don't resume syncs that started over a week ago. (#275)

ConductorOne · Dec 30, 2024 · 988c9e4 · 988c9e4
1 parent 0c9a018
commit 988c9e4
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/dotc1z/sync_runs.go b/pkg/dotc1z/sync_runs.go
@@ -60,10 +60,13 @@ func (c *C1File) getLatestUnfinishedSync(ctx context.Context) (*syncRun, error)
 		return nil, err
 	}
 
+	// Don't resume syncs that started over a week ago
+	oneWeekAgo := time.Now().AddDate(0, 0, -7)
 	ret := &syncRun{}
 	q := c.db.From(syncRuns.Name())
 	q = q.Select("sync_id", "started_at", "ended_at", "sync_token")
 	q = q.Where(goqu.C("ended_at").IsNull())
+	q = q.Where(goqu.C("started_at").Gte(oneWeekAgo))
 	q = q.Order(goqu.C("started_at").Desc())
 	q = q.Limit(1)