diff --git a/protokube/pkg/protokube/channels.go b/protokube/pkg/protokube/channels.go index 7ee58c6315a53..478d6e795b879 100644 --- a/protokube/pkg/protokube/channels.go +++ b/protokube/pkg/protokube/channels.go @@ -36,8 +36,8 @@ func applyChannel(channel string) error { } func execChannels(args ...string) (string, error) { - kubectlPath := "/opt/kops/bin/channels" - cmd := exec.Command(kubectlPath, args...) + channelsPath := "/opt/kops/bin/channels" + cmd := exec.Command(channelsPath, args...) env := os.Environ() cmd.Env = env diff --git a/upup/pkg/fi/executor.go b/upup/pkg/fi/executor.go index db1d6321aae20..16c2d5a286c70 100644 --- a/upup/pkg/fi/executor.go +++ b/upup/pkg/fi/executor.go @@ -134,7 +134,7 @@ func (e *executor) RunTasks(taskMap map[string]Task) error { remaining := time.Second * time.Duration(int(time.Until(ts.deadline).Seconds())) if _, ok := err.(*TryAgainLaterError); ok { - klog.Infof("Task %q not ready: %v", ts.key, err) + klog.V(2).Infof("Task %q not ready: %v", ts.key, err) } else { klog.Warningf("error running task %q (%v remaining to succeed): %v", ts.key, remaining, err) } diff --git a/upup/pkg/fi/task.go b/upup/pkg/fi/task.go index 6d561a661939e..aaa3863c6c731 100644 --- a/upup/pkg/fi/task.go +++ b/upup/pkg/fi/task.go @@ -98,18 +98,18 @@ func (c *ModelBuilderContext) setLifecycleOverride(task Task) Task { // TODO(@chrislovecnm) - wonder if we should update the nodeup tasks to have lifecycle // TODO - so that we can return an error here, rather than just returning. // certain tasks have not implemented HasLifecycle interface - hl, ok := task.(HasLifecycle) - if !ok { - klog.V(8).Infof("task %T does not implement HasLifecycle", task) - return task - } - typeName := TypeNameForTask(task) klog.V(8).Infof("testing task %q", typeName) // typeName can be values like "InternetGateway" value, ok := c.LifecycleOverrides[typeName] if ok { + hl, okHL := task.(HasLifecycle) + if !okHL { + klog.Warningf("task %T does not implement HasLifecycle", task) + return task + } + klog.Warningf("overriding task %s, lifecycle %s", task, value) hl.SetLifecycle(value) }