diff --git a/cmd/tk/create_kustomization.go b/cmd/tk/create_kustomization.go index e358f5334a3991c8d52b460b9695141457505c29..92b8057c84a111ac627eb0bb1cfc5c5cf515ee96 100644 --- a/cmd/tk/create_kustomization.go +++ b/cmd/tk/create_kustomization.go @@ -113,14 +113,6 @@ func createKsCmdRun(cmd *cobra.Command, args []string) error { return fmt.Errorf("path must begin with ./") } - ctx, cancel := context.WithTimeout(context.Background(), timeout) - defer cancel() - - kubeClient, err := utils.kubeClient(kubeconfig) - if err != nil { - return err - } - if !export { logger.Generatef("generating kustomization") } @@ -190,6 +182,14 @@ func createKsCmdRun(cmd *cobra.Command, args []string) error { return exportKs(kustomization) } + ctx, cancel := context.WithTimeout(context.Background(), timeout) + defer cancel() + + kubeClient, err := utils.kubeClient(kubeconfig) + if err != nil { + return err + } + logger.Actionf("applying kustomization") if err := upsertKustomization(ctx, kubeClient, kustomization); err != nil { return err diff --git a/cmd/tk/create_source_git.go b/cmd/tk/create_source_git.go index 9fa7d6f2d2f20daa2ff879313b66c5001379735d..31f3635c94d1ded7a349f595d7ca5fbce51b52d1 100644 --- a/cmd/tk/create_source_git.go +++ b/cmd/tk/create_source_git.go @@ -129,14 +129,6 @@ func createSourceGitCmdRun(cmd *cobra.Command, args []string) error { return fmt.Errorf("git URL parse failed: %w", err) } - ctx, cancel := context.WithTimeout(context.Background(), timeout) - defer cancel() - - kubeClient, err := utils.kubeClient(kubeconfig) - if err != nil { - return err - } - gitRepository := sourcev1.GitRepository{ ObjectMeta: metav1.ObjectMeta{ Name: name, @@ -163,6 +155,14 @@ func createSourceGitCmdRun(cmd *cobra.Command, args []string) error { return exportGit(gitRepository) } + ctx, cancel := context.WithTimeout(context.Background(), timeout) + defer cancel() + + kubeClient, err := utils.kubeClient(kubeconfig) + if err != nil { + return err + } + withAuth := false // TODO(hidde): move all auth prep to separate func? if u.Scheme == "ssh" { diff --git a/cmd/tk/create_source_helm.go b/cmd/tk/create_source_helm.go index 82ec91f100e2dc28584d87443332eb57b7199768..2037989cf45987652760c11a3eec64cc4353fba6 100644 --- a/cmd/tk/create_source_helm.go +++ b/cmd/tk/create_source_helm.go @@ -101,14 +101,6 @@ func createSourceHelmCmdRun(cmd *cobra.Command, args []string) error { return fmt.Errorf("url parse failed: %w", err) } - ctx, cancel := context.WithTimeout(context.Background(), timeout) - defer cancel() - - kubeClient, err := utils.kubeClient(kubeconfig) - if err != nil { - return err - } - helmRepository := sourcev1.HelmRepository{ ObjectMeta: metav1.ObjectMeta{ Name: name, @@ -126,6 +118,14 @@ func createSourceHelmCmdRun(cmd *cobra.Command, args []string) error { return exportHelmRepository(helmRepository) } + ctx, cancel := context.WithTimeout(context.Background(), timeout) + defer cancel() + + kubeClient, err := utils.kubeClient(kubeconfig) + if err != nil { + return err + } + logger.Generatef("generating source") secret := corev1.Secret{