add wait

Signed-off-by: ashnamehrotra <[email protected]>

test/e2e/tests/collector_delete_manager/eraser_test.go

@@ -13,6 +13,8 @@ import (
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/labels"
+	"sigs.k8s.io/e2e-framework/klient/wait"
+	"sigs.k8s.io/e2e-framework/klient/wait/conditions"
 	"sigs.k8s.io/e2e-framework/pkg/envconf"
 	"sigs.k8s.io/e2e-framework/pkg/features"
 )
@@ -58,6 +60,12 @@ func TestDeleteManager(t *testing.T) {
 				t.Error("unable to delete eraser-controller-manager pod")
 			}
 
+			// wait for deletion to finish
+			err = wait.For(conditions.New(c.Resources()).ResourcesDeleted(&podList), wait.WithTimeout(util.Timeout))
+			if err != nil {
+				t.Errorf("error waiting for manager pod to be deleted: %v", err)
+			}
+
 			// get new ImageJob
 			var jobList2 eraserv1alpha1.ImageJobList
 			err = c.Resources().List(ctx, &jobList2)