From 19e63bd41320241f1ff2667bf51fa6117d0f33b5 Mon Sep 17 00:00:00 2001 From: Jiahui <4543bxy@gmail.com> Date: Thu, 3 Jul 2025 11:42:14 +0800 Subject: [PATCH] Fix/skip terminal ns (#5675) * fix skip namespace terminating status * processUsersInParallel semaphore to 1000 --- controllers/account/controllers/debt.go | 2 +- service/account/api/subscription.go | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/controllers/account/controllers/debt.go b/controllers/account/controllers/debt.go index 8434f7085..fb5c807d8 100644 --- a/controllers/account/controllers/debt.go +++ b/controllers/account/controllers/debt.go @@ -540,7 +540,7 @@ func (r *DebtReconciler) retryFailedUsers() { func (r *DebtReconciler) processUsersInParallel(users []uuid.UUID) { var ( wg sync.WaitGroup - semaphore = make(chan struct{}, 50) + semaphore = make(chan struct{}, 1000) ) for _, user := range users { diff --git a/service/account/api/subscription.go b/service/account/api/subscription.go index 4287c14c6..0cf6b584b 100644 --- a/service/account/api/subscription.go +++ b/service/account/api/subscription.go @@ -260,6 +260,9 @@ func getOwnNsListWithClt(clt client.Client, user string) ([]string, error) { } nsListStr := make([]string, len(nsList.Items)) for i := range nsList.Items { + if nsList.Items[i].Status.Phase == corev1.NamespaceTerminating { + continue + } nsListStr[i] = nsList.Items[i].Name } return nsListStr, nil