From 2e463348b26fb8b36657b8cb6871e4bce8030b0b Mon Sep 17 00:00:00 2001 From: Artem Chernyshev Date: Thu, 15 Jul 2021 18:13:29 +0300 Subject: [PATCH] fix: pass all logs through the options.Log method Looks like I've missed some :facepalm: Signed-off-by: Artem Chernyshev --- pkg/cluster/kubernetes/talos_managed.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/cluster/kubernetes/talos_managed.go b/pkg/cluster/kubernetes/talos_managed.go index 752cbb25d..4c5e8f640 100644 --- a/pkg/cluster/kubernetes/talos_managed.go +++ b/pkg/cluster/kubernetes/talos_managed.go @@ -75,7 +75,7 @@ func UpgradeTalosManaged(ctx context.Context, cluster UpgradeProvider, options U if err = hyperkubeUpgradeDs(ctx, k8sClient.Clientset, kubeProxy, options); err != nil { if apierrors.IsNotFound(err) { - fmt.Println("kube-proxy skipped as DaemonSet was not found") + options.Log("kube-proxy skipped as DaemonSet was not found") } else { return fmt.Errorf("error updating kube-proxy: %w", err) } @@ -142,8 +142,8 @@ func upgradeNodeConfigPatch(ctx context.Context, cluster UpgradeProvider, option } } - fmt.Printf(" > %q: machine configuration patched\n", node) - fmt.Printf(" > %q: waiting for API server state pod update\n", node) + options.Log(" > %q: machine configuration patched", node) + options.Log(" > %q: waiting for API server state pod update", node) var expectedConfigVersion string @@ -170,7 +170,7 @@ func upgradeNodeConfigPatch(ctx context.Context, cluster UpgradeProvider, option return err } - fmt.Printf(" < %q: successfully updated\n", node) + options.Log(" < %q: successfully updated", node) return nil }