Fix: add ns filter to podLister (#622)

kubeflow · Feb 6, 2024 · a1ff84c · a1ff84c
1 parent 4c9ac06
commit a1ff84c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/controller/mpi_job_controller.go b/pkg/controller/mpi_job_controller.go
@@ -808,7 +808,7 @@ func (c *MPIJobController) getRunningWorkerPods(mpiJob *kubeflow.MPIJob) ([]*cor
 	if err != nil {
 		return nil, err
 	}
-	podFullList, err := c.podLister.List(selector)
+	podFullList, err := c.podLister.Pods(mpiJob.Namespace).List(selector)
 	if err != nil {
 		return nil, err
 	}
@@ -956,7 +956,7 @@ func (c *MPIJobController) getOrCreateWorker(mpiJob *kubeflow.MPIJob) ([]*corev1
 	if err != nil {
 		return nil, err
 	}
-	podFullList, err := c.podLister.List(selector)
+	podFullList, err := c.podLister.Pods(mpiJob.Namespace).List(selector)
 	if err != nil {
 		return nil, err
 	}