Skip to content

Commit 722f88c

Browse files
author
lamai93
committed
Only restart coordinators if the deployment mode has coordinators.
1 parent f363f22 commit 722f88c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pkg/deployment/resources/pod_inspector.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -237,7 +237,7 @@ func (r *Resources) InspectPods(ctx context.Context) (util.Interval, error) {
237237
allMembersReady := status.Members.AllMembersReady(spec.GetMode(), spec.Sync.IsEnabled())
238238
status.Conditions.Update(api.ConditionTypeReady, allMembersReady, "", "")
239239

240-
if status.Members.Coordinators.AllFailed() {
240+
if spec.GetMode().HasCoordinators() && status.Members.Coordinators.AllFailed() {
241241
log.Error().Msg("All coordinators failed - reset")
242242
for _, m := range status.Members.Coordinators {
243243
if err := r.context.DeletePod(m.PodName); err != nil {

0 commit comments

Comments
 (0)