From b4426297bccd770e1a1aae51957e4eecf4b7ab18 Mon Sep 17 00:00:00 2001 From: James Munnelly Date: Tue, 8 Sep 2015 00:00:52 +0100 Subject: [PATCH] Wait for pod to enter running state. Wait for pod to complete before exiting. --- main.go | 24 ++++++++++++++++++++++++ 1 file changed, 24 insertions(+) diff --git a/main.go b/main.go index 6bab6d7..3acd56e 100644 --- a/main.go +++ b/main.go @@ -48,4 +48,28 @@ func main() { if err != nil { log.Fatal("Job start failed with error: ", err) } + + log.Print("Waiting for build pod to enter Running state...") + + err = job.WaitForState(api.PodRunning) + if err != nil { + log.Fatal("Error waiting for pod to enter running state: ", err) + } + + log.Print("Job has started running...") + log.Print("Waiting for job to complete...") + + err = job.WaitForState(api.PodSucceeded) + if err != nil { + log.Fatal("Error waiting for job to complete: ", err) + } + + log.Print("Job completed. Destroying pod...") + + err = job.Stop() + if err != nil { + log.Fatal("Error stopping job: ", err) + } + + log.Print("Pod destroyed. Exiting.") }