Skip to content

Commit 4ae19ec

Browse files
pd only reconcile active pods (#260)
1 parent 7458332 commit 4ae19ec

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

pkg/controllers/poddecoration/poddecoration_controller.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,8 @@ import (
4040
"sigs.k8s.io/controller-runtime/pkg/source"
4141

4242
appsv1alpha1 "kusionstack.io/kube-api/apps/v1alpha1"
43+
44+
"kusionstack.io/kuperator/pkg/controllers/collaset/podcontrol"
4345
controllerutils "kusionstack.io/kuperator/pkg/controllers/utils"
4446
"kusionstack.io/kuperator/pkg/controllers/utils/expectations"
4547
utilspoddecoration "kusionstack.io/kuperator/pkg/controllers/utils/poddecoration/anno"
@@ -167,6 +169,9 @@ func (r *ReconcilePodDecoration) Reconcile(ctx context.Context, request reconcil
167169
return reconcile.Result{}, err
168170
}
169171
for i := range podList.Items {
172+
if podcontrol.IsPodInactive(&podList.Items[i]) || podList.Items[i].DeletionTimestamp != nil {
173+
continue
174+
}
170175
selectedPods = append(selectedPods, &podList.Items[i])
171176
}
172177
affectedPods, affectedCollaSets, err := r.filterOutPodAndCollaSet(selectedPods)

0 commit comments

Comments
 (0)