test

test/k8snode_block_list_test.go

@@ -17,7 +17,7 @@ const (
 	wrongImage = "wrong-image"
 )
 
-var _ = Describe(
+var _ = FDescribe(
 	"K8sNodeBlockList", func() {
 		ctx := context.TODO()
 		Context(

test/large_reconcile_test.go

@@ -43,7 +43,7 @@ var _ = Describe(
 				}
 				aeroCluster.Spec.AerospikeNetworkPolicy = networkPolicy
 
-				It(
+				FIt(
 					"Should try large reconcile operations", func() {
 
 						By("Deploy and load data")
@@ -111,14 +111,16 @@ var _ = Describe(
 						Expect(err).ToNot(HaveOccurred())
 
 						// Change config back to original value
-						aeroCluster, err = getCluster(
-							k8sClient, ctx, clusterNamespacedName,
-						)
-						Expect(err).ToNot(HaveOccurred())
+						Eventually(func() error {
+							aeroCluster, err = getCluster(
+								k8sClient, ctx, clusterNamespacedName,
+							)
+							Expect(err).ToNot(HaveOccurred())
 
-						aeroCluster.Spec.AerospikeConfig.Value["service"].(map[string]interface{})["proto-fd-max"] = defaultProtofdmax
-						err = k8sClient.Update(goctx.TODO(), aeroCluster)
-						Expect(err).ToNot(HaveOccurred())
+							aeroCluster.Spec.AerospikeConfig.Value["service"].(map[string]interface{})["proto-fd-max"] = defaultProtofdmax
+
+							return k8sClient.Update(goctx.TODO(), aeroCluster)
+						}, 1*time.Minute).ShouldNot(HaveOccurred())
 
 						// Cluster status should never get updated with old conf "tempConf"
 						err = waitForClusterRollingRestart(

test/utils.go

@@ -293,6 +293,8 @@ func isClusterStateValid(
 
 	if !reflect.DeepEqual(statusToSpec, &newCluster.Spec) {
 		pkgLog.Info("Cluster status is not matching the spec")
+		pkgLog.Info(fmt.Sprintf("statusToSpec: %+v", statusToSpec))
+		pkgLog.Info(fmt.Sprintf("newCluster.Spec: %+v", newCluster.Spec))
 		return false
 	}