From f5e977b8ed3f0bda69e9b71e1e9be8e79d06c7d4 Mon Sep 17 00:00:00 2001 From: Per Hermansson Date: Mon, 20 May 2019 21:43:09 +0200 Subject: [PATCH] Skip waiting for paused deployments Signed-off-by: Per Hermansson --- pkg/kube/wait.go | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/pkg/kube/wait.go b/pkg/kube/wait.go index 48ae4c1b5..4c4bb9ddc 100644 --- a/pkg/kube/wait.go +++ b/pkg/kube/wait.go @@ -69,6 +69,10 @@ func (w *waiter) waitForResources(created ResourceList) error { if err != nil { return false, err } + // If paused deployment will never be ready + if currentDeployment.Spec.Paused { + continue + } // Find RS associated with deployment newReplicaSet, err := deploymentutil.GetNewReplicaSet(currentDeployment, w.c.AppsV1()) if err != nil || newReplicaSet == nil { @@ -82,6 +86,10 @@ func (w *waiter) waitForResources(created ResourceList) error { if err != nil { return false, err } + // If paused deployment will never be ready + if currentDeployment.Spec.Paused { + continue + } // Find RS associated with deployment newReplicaSet, err := deploymentutil.GetNewReplicaSet(currentDeployment, w.c.AppsV1()) if err != nil || newReplicaSet == nil { @@ -95,6 +103,10 @@ func (w *waiter) waitForResources(created ResourceList) error { if err != nil { return false, err } + // If paused deployment will never be ready + if currentDeployment.Spec.Paused { + continue + } // Find RS associated with deployment newReplicaSet, err := deploymentutil.GetNewReplicaSet(currentDeployment, w.c.AppsV1()) if err != nil || newReplicaSet == nil { @@ -108,6 +120,10 @@ func (w *waiter) waitForResources(created ResourceList) error { if err != nil { return false, err } + // If paused deployment will never be ready + if currentDeployment.Spec.Paused { + continue + } // Find RS associated with deployment newReplicaSet, err := deploymentutil.GetNewReplicaSet(currentDeployment, w.c.AppsV1()) if err != nil || newReplicaSet == nil {