diff --git a/cluster/syncer/status.go b/cluster/syncer/status.go index 02df3904..06ede056 100644 --- a/cluster/syncer/status.go +++ b/cluster/syncer/status.go @@ -226,7 +226,9 @@ func (s *StatusSyncer) updateNodeStatus(ctx context.Context, cli client.Client, log.Error(err, "cannot update pod", "name", podName, "namespace", pod.Namespace) } } - + if len(pods) != int(*s.Spec.Replicas) { + return fmt.Errorf("not all replicas do something") + } return nil }