Skip to content

Commit

Permalink
Only log HasLifecycle details if it is worthy of a warning
Browse files Browse the repository at this point in the history
  • Loading branch information
rifelpet committed Mar 20, 2021
1 parent 14bbcec commit 7f32b2a
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion upup/pkg/fi/executor.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
Expand Down
12 changes: 6 additions & 6 deletions upup/pkg/fi/task.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
Expand Down

0 comments on commit 7f32b2a

Please sign in to comment.