Add additional logging

deliveroo · Jan 12, 2018 · e95a851 · e95a851
1 parent c7593e4
commit e95a851
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/cli/pipeline/run.go b/cli/pipeline/run.go
@@ -159,6 +159,8 @@ func runPipelineStep(pipeline *PipelineDefinition, step *PipelineDefinitionStep,
 					TailLogs(ctx, clientset, e.Pod, e.Container)
 				}
 			case Deleted:
+				log.Println("[paddle] Pod deleted")
+				return errors.New("Pod was deleted unexpectedly.")
 			case Removed:
 				log.Printf("[paddle] Container removed: %s", e.Container)
 				continue

diff --git a/cli/pipeline/watch.go b/cli/pipeline/watch.go
@@ -49,8 +49,10 @@ func Watch(ctx context.Context, c kubernetes.Interface, watchPod *v1.Pod) (<-cha
 
 	parsePodStatus := func(pod *v1.Pod) {
 		if pod.Status.Phase == v1.PodSucceeded {
+			log.Println("Status: succeded")
 			out <- WatchEvent{Completed, pod, "", ""}
 		} else if pod.Status.Phase == v1.PodFailed {
+			log.Println("Status: failed")
 			out <- WatchEvent{Failed, pod, "", ""}
 		} else {
 			for _, container := range pod.Status.ContainerStatuses {
@@ -105,6 +107,7 @@ func Watch(ctx context.Context, c kubernetes.Interface, watchPod *v1.Pod) (<-cha
 		for {
 			select {
 			case <-time.After(watchPollInterval):
+				log.Println("Polling pod status:")
 				pod, err := c.CoreV1().Pods(watchPod.Namespace).Get(watchPod.Name, metav1.GetOptions{})
 				if err != nil {
 					parsePodStatus(pod)