use context with timeout from rootArgs

Signed-off-by: Chanwit Kaewkasi <[email protected]>
flux-subsystem-argo · Nov 7, 2023 · 9458616 · 9458616
1 parent 6532989
commit 9458616
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/cmd/flamingo/install.go b/cmd/flamingo/install.go
@@ -291,7 +291,10 @@ func installFluxSubsystemForArgo(candidate Candidate, installMode string, anonym
 		// install everything
 		logger.Actionf("installing components in %s namespace", rootArgs.applicationNamespace)
 	}
-	applyOutput, err := utils.Apply(context.Background(), kubeconfigArgs, kubeclientOptions, yamlOutput)
+
+	ctx, cancelFn := context.WithTimeout(context.Background(), rootArgs.timeout)
+	defer cancelFn()
+	applyOutput, err := utils.Apply(ctx, kubeconfigArgs, kubeclientOptions, yamlOutput)
 	if err != nil {
 		return fmt.Errorf("install failed: %w", err)
 	}