tweak: set sync-timeout

fluxcd · Dec 7, 2020 · 5953024 · 5953024
1 parent 64ee50f
commit 5953024
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/daemon/sync.go b/pkg/daemon/sync.go
@@ -45,6 +45,9 @@ type changeSet struct {
 
 // Sync starts the synchronization of the cluster with git.
 func (d *Daemon) Sync(ctx context.Context, started time.Time, newRevision string, rat ratchet) error {
+	ctx, cancel := context.WithTimeout(ctx, d.SyncTimeout)
+	defer cancel()
+
 	// Load last-synced resources for comparison
 	lastResources, err := d.getLastResources(ctx, rat)
 	if err != nil {