added

Signed-off-by: nXtCyberNet <rohantech2005@gmail.com>

Author: nXtCyberNet

test/e2e/suites/base/dependenciesdistributor_test.go

@@ -212,6 +212,13 @@ var _ = ginkgo.Describe("[DependenciesDistributor] automatically propagate relev
 						func(*corev1.Secret) bool {
 							return true
 						})
+
+					ginkgo.By("checking GetDependenciesSucceed event on deployment", func() {
+						framework.WaitEventFitWith(kubeClient, deployment.Namespace, deployment.Name,
+							func(event corev1.Event) bool {
+								return event.Reason == events.EventReasonGetDependenciesSucceed
+							})
+					})
 				})
 
 				ginkgo.By("make the secret is not referenced by the deployment ", func() {
@@ -282,13 +289,19 @@ var _ = ginkgo.Describe("[DependenciesDistributor] automatically propagate relev
 						func(*appsv1.Deployment) bool {
 							return true
 						})
-
 					framework.WaitPVCPresentOnClustersFitWith(initClusterNames, pvc.GetNamespace(), pvc.GetName(),
 						func(*corev1.PersistentVolumeClaim) bool {
 							return true
 						})
 				})
 
+				ginkgo.By("checking GetDependenciesSucceed event on deployment", func() {
+					framework.WaitEventFitWith(kubeClient, deployment.Namespace, deployment.Name,
+						func(event corev1.Event) bool {
+							return event.Reason == events.EventReasonGetDependenciesSucceed
+						})
+				})
+
 				ginkgo.By("make the persistentVolumeClaim is not referenced by the deployment ", func() {
 					updateVolumes := []corev1.Volume{
 						{
@@ -349,6 +362,12 @@ var _ = ginkgo.Describe("[DependenciesDistributor] automatically propagate relev
 							return true
 						})
 				})
+				ginkgo.By("checking GetDependenciesSucceed event on deployment", func() {
+					framework.WaitEventFitWith(kubeClient, deployment.Namespace, deployment.Name,
+						func(event corev1.Event) bool {
+							return event.Reason == events.EventReasonGetDependenciesSucceed
+						})
+				})
 
 				ginkgo.By("make the sa is not referenced by the deployment ", func() {
 					framework.UpdateDeploymentServiceAccountName(kubeClient, deployment, "default")

test/e2e/suites/base/overridepolicy_test.go

@@ -114,6 +114,12 @@ var _ = ginkgo.Describe("[OverridePolicy] apply overriders testing", func() {
 
 		ginkgo.It("deployment labelsOverride testing", func() {
 			klog.Infof("check if deployment present on member clusters have correct labels value")
+			ginkgo.By("checking ApplyOverridePolicySucceed event on deployment", func() {
+				framework.WaitEventFitWith(kubeClient, deploymentNamespace, deploymentName,
+					func(event corev1.Event) bool {
+						return event.Reason == events.EventReasonApplyOverridePolicySucceed
+					})
+			})
 			framework.WaitDeploymentPresentOnClustersFitWith(framework.ClusterNames(), deployment.Namespace, deployment.Name,
 				func(deployment *appsv1.Deployment) bool {
 					_, labelBarExist := deployment.GetLabels()["bar"]
@@ -122,12 +128,7 @@ var _ = ginkgo.Describe("[OverridePolicy] apply overriders testing", func() {
 						deployment.GetLabels()["foo"] == "exist" &&
 						deployment.GetLabels()["app"] == "nginx"
 				})
-			ginkgo.By("checking ApplyOverridePolicySucceed event on deployment", func() {
-				framework.WaitEventFitWith(kubeClient, deploymentNamespace, deploymentName,
-					func(event corev1.Event) bool {
-						return event.Reason == events.EventReasonApplyOverridePolicySucceed
-					})
-			})
+
 		})
 	})
 	ginkgo.Context("[AnnotationsOverrider] apply annotations overrider testing", func() {

test/e2e/suites/base/preemption_test.go

@@ -147,6 +147,7 @@ var _ = ginkgo.Describe("[Preemption] propagation policy preemption testing", fu
 
 			ginkgo.It("Propagate the deployment with the ClusterPropagationPolicy and then create the PropagationPolicy to preempt it", func() {
 				ginkgo.By("Wait for propagating deployment by the ClusterPropagationPolicy", func() {
+
 					framework.WaitDeploymentPresentOnClusterFitWith(preemptedClusterName, deployment.Namespace, deployment.Name, func(*appsv1.Deployment) bool { return true })
 				})
 
@@ -231,6 +232,13 @@ var _ = ginkgo.Describe("[Preemption] propagation policy preemption testing", fu
 					framework.PatchPropagationPolicy(karmadaClient, highPriorityPolicy.Namespace, highPriorityPolicy.Name, patch, types.JSONPatchType)
 					framework.WaitDeploymentPresentOnClusterFitWith(preemptingClusterName, deployment.Namespace, deployment.Name, func(*appsv1.Deployment) bool { return true })
 				})
+
+				ginkgo.By("checking PreemptPolicySucceed event on deployment", func() {
+					framework.WaitEventFitWith(kubeClient, deployment.Namespace, deployment.Name,
+						func(event corev1.Event) bool {
+							return event.Reason == events.EventReasonPreemptPolicySucceed
+						})
+				})
 			})
 		})
 	})
@@ -363,6 +371,13 @@ var _ = ginkgo.Describe("[Preemption] propagation policy preemption testing", fu
 					framework.PatchClusterPropagationPolicy(karmadaClient, highPriorityPolicy.Name, patch, types.JSONPatchType)
 					framework.WaitDeploymentPresentOnClusterFitWith(preemptingClusterName, deployment.Namespace, deployment.Name, func(*appsv1.Deployment) bool { return true })
 				})
+
+				ginkgo.By("checking PreemptPolicySucceed event on deployment", func() {
+					framework.WaitEventFitWith(kubeClient, deployment.Namespace, deployment.Name,
+						func(event corev1.Event) bool {
+							return event.Reason == events.EventReasonPreemptPolicySucceed
+						})
+				})
 			})
 		})
 	})