From 9c8b2343b196aae1a1a6c4e3f4bbeba9363362ed Mon Sep 17 00:00:00 2001 From: ajanikow <12255597+ajanikow@users.noreply.github.com> Date: Wed, 16 Dec 2020 02:02:44 +0000 Subject: [PATCH] Fix rotating phase --- pkg/deployment/resources/pod_inspector.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/deployment/resources/pod_inspector.go b/pkg/deployment/resources/pod_inspector.go index b6a34fb78..335c81fd7 100644 --- a/pkg/deployment/resources/pod_inspector.go +++ b/pkg/deployment/resources/pod_inspector.go @@ -202,7 +202,7 @@ func (r *Resources) InspectPods(ctx context.Context, cachedStatus inspector.Insp case api.MemberPhaseNone: // Do nothing log.Debug().Str("pod-name", podName).Msg("PodPhase is None, waiting for the pod to be recreated") - case api.MemberPhaseShuttingDown, api.MemberPhaseRotating, api.MemberPhaseUpgrading, api.MemberPhaseFailed: + case api.MemberPhaseShuttingDown, api.MemberPhaseUpgrading, api.MemberPhaseFailed: // Shutdown was intended, so not need to do anything here. // Just mark terminated wasTerminated := m.Conditions.IsTrue(api.ConditionTypeTerminated) @@ -217,6 +217,7 @@ func (r *Resources) InspectPods(ctx context.Context, cachedStatus inspector.Insp return maskAny(err) } } + case api.MemberPhaseRotating: fallthrough default: log.Debug().Str("pod-name", podName).Msg("Pod is gone")