From 9ff9a6e075a3ec3ee84019124d370235b7635876 Mon Sep 17 00:00:00 2001
From: Shubham Bansal <62992590+shubham-bansal96@users.noreply.github.com>
Date: Mon, 31 Oct 2022 12:55:57 +0530
Subject: [PATCH] newdeploy executor  to work with specific namespaces (#2590)

---
 .../executortype/newdeploy/newdeploymgr.go       | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git a/pkg/executor/executortype/newdeploy/newdeploymgr.go b/pkg/executor/executortype/newdeploy/newdeploymgr.go
index 5d498b22..f25036bf 100644
--- a/pkg/executor/executortype/newdeploy/newdeploymgr.go
+++ b/pkg/executor/executortype/newdeploy/newdeploymgr.go
@@ -778,14 +778,16 @@ func (deploy *NewDeploy) idleObjectReaper(ctx context.Context) {
 }
 
 func (deploy *NewDeploy) doIdleObjectReaper(ctx context.Context) {
-	envs, err := deploy.fissionClient.CoreV1().Environments(metav1.NamespaceAll).List(ctx, metav1.ListOptions{})
-	if err != nil {
-		deploy.logger.Fatal("failed to get environment list", zap.Error(err))
-	}
-
 	envList := make(map[k8sTypes.UID]struct{})
-	for _, env := range envs.Items {
-		envList[env.ObjectMeta.UID] = struct{}{}
+	for _, namespace := range utils.GetNamespaces() {
+		envs, err := deploy.fissionClient.CoreV1().Environments(namespace).List(ctx, metav1.ListOptions{})
+		if err != nil {
+			deploy.logger.Fatal("failed to get environment list", zap.Error(err), zap.String("namespace", namespace))
+		}
+
+		for _, env := range envs.Items {
+			envList[env.ObjectMeta.UID] = struct{}{}
+		}
 	}
 
 	funcSvcs, err := deploy.fsCache.ListOld(time.Second * 5)