Merge pull request #3381 from jumpeiMano/set-sync-timeout

perf: set sync-timeout
fluxcd · Apr 23, 2021 · cf97726 · cf97726
2 parents 5777baa + b6026ff
commit cf97726
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 {