Skip to content

Commit 50218df

Browse files
authored
[Bugfix] Move terminaton log before pod is terminated (#630)
1 parent f474a3b commit 50218df

File tree

2 files changed

+14
-15
lines changed

2 files changed

+14
-15
lines changed

pkg/deployment/resources/pod_inspector.go

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,20 @@ func (r *Resources) InspectPods(ctx context.Context, cachedStatus inspector.Insp
111111
// Pod has terminated with at least 1 container with a non-zero exit code.
112112
wasTerminated := memberStatus.Conditions.IsTrue(api.ConditionTypeTerminated)
113113
if memberStatus.Conditions.Update(api.ConditionTypeTerminated, true, "Pod Failed", "") {
114+
if c, ok := k8sutil.GetContainerStatusByName(pod, k8sutil.ServerContainerName); ok {
115+
if t := c.State.Terminated; t != nil {
116+
log.Warn().Str("member", memberStatus.ID).
117+
Str("pod", pod.GetName()).
118+
Str("uid", string(pod.GetUID())).
119+
Int32("exit-code", t.ExitCode).
120+
Str("reason", t.Reason).
121+
Str("message", t.Message).
122+
Int32("signal", t.Signal).
123+
Time("started", t.StartedAt.Time).
124+
Time("finished", t.FinishedAt.Time).
125+
Msgf("Pod failed in unexpected way")
126+
}
127+
}
114128
log.Debug().Str("pod-name", pod.GetName()).Msg("Updating member condition Terminated to true: Pod Failed")
115129
updateMemberStatusNeeded = true
116130
nextInterval = nextInterval.ReduceTo(recheckSoonPodInspectorInterval)

pkg/deployment/resources/pod_termination.go

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -131,21 +131,6 @@ func (r *Resources) prepareDBServerPodTermination(ctx context.Context, log zerol
131131
return nil
132132
}
133133

134-
if c, ok := k8sutil.GetContainerStatusByName(p, k8sutil.ServerContainerName); ok {
135-
if t := c.State.Terminated; t != nil {
136-
log.Warn().Str("member", memberStatus.ID).
137-
Str("pod", p.GetName()).
138-
Str("uid", string(p.GetUID())).
139-
Int32("exit-code", t.ExitCode).
140-
Str("reason", t.Reason).
141-
Str("message", t.Message).
142-
Int32("signal", t.Signal).
143-
Time("started", t.StartedAt.Time).
144-
Time("finished", t.FinishedAt.Time).
145-
Msgf("Pod failed in unexpected way")
146-
}
147-
}
148-
149134
// Inspect deployment deletion state
150135
apiObject := r.context.GetAPIObject()
151136
if apiObject.GetDeletionTimestamp() != nil {

0 commit comments

Comments
 (0)