Skip to content
This repository has been archived by the owner on Dec 9, 2022. It is now read-only.

Commit

Permalink
More logging
Browse files Browse the repository at this point in the history
  • Loading branch information
me committed Jan 12, 2018
1 parent 2bdc4dd commit c1b79c3
Showing 1 changed file with 8 additions and 2 deletions.
10 changes: 8 additions & 2 deletions cli/pipeline/watch.go
Original file line number Diff line number Diff line change
Expand Up @@ -107,10 +107,16 @@ func Watch(ctx context.Context, c kubernetes.Interface, watchPod *v1.Pod) (<-cha
for {
select {
case <-time.After(watchPollInterval):
log.Println("Polling pod status:")
log.Println("Polling pod status")
pod, err := c.CoreV1().Pods(watchPod.Namespace).Get(watchPod.Name, metav1.GetOptions{})
if err != nil {
if pod != nil {
parsePodStatus(pod)
} else {
if err != nil {
log.Println("Error polling pod status: %s", err.Error())
} else {
log.Println("No pod status")
}
}
case <-ctx.Done():
return
Expand Down

0 comments on commit c1b79c3

Please sign in to comment.