diff --git a/test/e2e/case20_delete_objects_test.go b/test/e2e/case20_delete_objects_test.go
index e61c3d5b..0f6d50a2 100644
--- a/test/e2e/case20_delete_objects_test.go
+++ b/test/e2e/case20_delete_objects_test.go
@@ -323,7 +323,7 @@ var _ = Describe("Test Object deletion", Ordered, func() {
 					case20PodName, "default", true, defaultTimeoutSeconds)
 
 				return pod
-			}, 30, 1).Should(Not(BeNil()))
+			}, defaultTimeoutSeconds, 1).Should(Not(BeNil()))
 			By("Creating " + case20ConfigPolicyNameExisting + " on managed")
 			utils.Kubectl("apply", "-f", case20PolicyYamlExisting, "-n", testNamespace)
 			plc := utils.GetWithTimeout(clientManagedDynamic, gvrConfigPolicy,
diff --git a/test/e2e/case23_invalid_field_test.go b/test/e2e/case23_invalid_field_test.go
index 69d083c9..b66996fd 100644
--- a/test/e2e/case23_invalid_field_test.go
+++ b/test/e2e/case23_invalid_field_test.go
@@ -73,7 +73,7 @@ var _ = Describe("Test an objectDefinition with an invalid field", Ordered, func
 			}
 
 			return startTime.After(compPlcEvents[len(compPlcEvents)-1].LastTimestamp.Time)
-		}, 30, 1).Should(BeTrue())
+		}, defaultConsistentlyDuration, 1).Should(BeTrue())
 
 		By("Verifying the message is correct when the " + configMapName + " ConfigMap already exists")
 		configmap := &corev1.ConfigMap{
@@ -118,7 +118,7 @@ var _ = Describe("Test an objectDefinition with an invalid field", Ordered, func
 			}
 
 			return alreadyExistsStartTime.After(compPlcEvents[len(compPlcEvents)-1].LastTimestamp.Time)
-		}, 30, 1).Should(BeTrue())
+		}, defaultConsistentlyDuration, 1).Should(BeTrue())
 	})
 
 	AfterAll(func() {