diff --git a/test/k8snode_block_list_test.go b/test/k8snode_block_list_test.go index 8dcc9f456..38c4bbe17 100644 --- a/test/k8snode_block_list_test.go +++ b/test/k8snode_block_list_test.go @@ -17,7 +17,7 @@ const ( wrongImage = "wrong-image" ) -var _ = Describe( +var _ = FDescribe( "K8sNodeBlockList", func() { ctx := context.TODO() Context( diff --git a/test/large_reconcile_test.go b/test/large_reconcile_test.go index 26d731455..2ba24e942 100644 --- a/test/large_reconcile_test.go +++ b/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( diff --git a/test/utils.go b/test/utils.go index 78207c235..8763b9d2b 100644 --- a/test/utils.go +++ b/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 }