@@ -151,7 +151,7 @@ var _ = Describe("Operator", func() {
151151 Expect (rmqClusterClient .Delete (context .TODO (), cluster )).To (Succeed ())
152152 })
153153
154- It ("keeps rabbitmq server related configurations up-to-date" , func () {
154+ FIt ("keeps rabbitmq server related configurations up-to-date" , func () {
155155 By ("updating enabled plugins and the secret ports when additionalPlugins are modified" , func () {
156156 // modify rabbitmqcluster.spec.rabbitmq.additionalPlugins
157157 Expect (updateRabbitmqCluster (ctx , rmqClusterClient , cluster .Name , cluster .Namespace , func (cluster * rabbitmqv1beta1.RabbitmqCluster ) {
@@ -164,7 +164,7 @@ var _ = Describe("Operator", func() {
164164 Expect (err ).ToNot (HaveOccurred ())
165165 return configMap .Annotations
166166 }
167- Eventually (getConfigMapAnnotations , 30 , 1 ).Should (
167+ Eventually (getConfigMapAnnotations , 1 * time . Minute , 1 ).Should (
168168 HaveKey ("rabbitmq.com/pluginsUpdatedAt" ), "plugins ConfigMap should have been annotated" )
169169 Eventually (getConfigMapAnnotations , 4 * time .Minute , 1 ).Should (
170170 Not (HaveKey ("rabbitmq.com/pluginsUpdatedAt" )), "plugins ConfigMap annotation should have been removed" )
@@ -592,7 +592,7 @@ CONSOLE_LOG=new`
592592
593593 })
594594
595- FWhen ("stream plugin is enabled" , func () {
595+ When ("stream plugin is enabled" , func () {
596596 var (
597597 cluster * rabbitmqv1beta1.RabbitmqCluster
598598 hostname string
0 commit comments