Add propagation policy when deleting Job

Author: bjee19

tests/framework/resourcemanager.go

@@ -124,12 +124,12 @@ func (rm *ResourceManager) ApplyFromFiles(files []string, namespace string) erro
 }
 
 // Delete deletes Kubernetes resources defined as Go objects.
-func (rm *ResourceManager) Delete(resources []client.Object) error {
+func (rm *ResourceManager) Delete(resources []client.Object, opts ...client.DeleteOption) error {
 	for _, resource := range resources {
 		ctx, cancel := context.WithTimeout(context.Background(), rm.TimeoutConfig.DeleteTimeout)
 		defer cancel()
 
-		if err := rm.K8sClient.Delete(ctx, resource); err != nil && !apierrors.IsNotFound(err) {
+		if err := rm.K8sClient.Delete(ctx, resource, opts...); err != nil && !apierrors.IsNotFound(err) {
 			return fmt.Errorf("error deleting resource: %w", err)
 		}
 	}

tests/suite/graceful_recovery_test.go

@@ -131,7 +131,8 @@ func restartNginxContainer() {
 	err = waitForContainerRestart(podNames[0], nginxContainerName, restartCount)
 	Expect(err).ToNot(HaveOccurred())
 
-	err = resourceManager.Delete([]client.Object{job})
+	// propagation policy is set to delete underlying pod created through job
+	err = resourceManager.Delete([]client.Object{job}, client.PropagationPolicy(metav1.DeletePropagationBackground))
 	Expect(err).ToNot(HaveOccurred())
 }
 
@@ -149,7 +150,8 @@ func restartNGFProcess() {
 	err = waitForContainerRestart(podNames[0], ngfContainerName, restartCount)
 	Expect(err).ToNot(HaveOccurred())
 
-	err = resourceManager.Delete([]client.Object{job})
+	// propagation policy is set to delete underlying pod created through job
+	err = resourceManager.Delete([]client.Object{job}, client.PropagationPolicy(metav1.DeletePropagationBackground))
 	Expect(err).ToNot(HaveOccurred())
 }