@@ -207,7 +207,7 @@ var _ = Describe("controller", func() {
207
207
}()
208
208
209
209
<- sourceSynced
210
- }, 10.0 )
210
+ })
211
211
212
212
It ("should process events from source.Channel" , func () {
213
213
// channel to be closed when event is processed
@@ -518,8 +518,8 @@ var _ = Describe("controller", func() {
518
518
519
519
By ("Removing the item from the queue" )
520
520
Eventually (queue .Len ).Should (Equal (0 ))
521
- Eventually (func () int { return queue .NumRequeues (request ) }).Should (Equal (0 ))
522
- }, 1.0 )
521
+ Eventually (func () int { return queue .NumRequeues (request ) }, 1.0 ).Should (Equal (0 ))
522
+ })
523
523
524
524
// TODO(directxman12): we should ensure that backoff occurrs with error requeue
525
525
@@ -695,7 +695,7 @@ var _ = Describe("controller", func() {
695
695
}
696
696
return nil
697
697
}, 2.0 ).Should (Succeed ())
698
- }, 2.0 )
698
+ })
699
699
700
700
It ("should get updated on reconcile errors" , func () {
701
701
Expect (func () error {
@@ -724,7 +724,7 @@ var _ = Describe("controller", func() {
724
724
}
725
725
return nil
726
726
}, 2.0 ).Should (Succeed ())
727
- }, 2.0 )
727
+ })
728
728
729
729
It ("should get updated when reconcile returns with retry enabled" , func () {
730
730
Expect (func () error {
@@ -754,7 +754,7 @@ var _ = Describe("controller", func() {
754
754
}
755
755
return nil
756
756
}, 2.0 ).Should (Succeed ())
757
- }, 2.0 )
757
+ })
758
758
759
759
It ("should get updated when reconcile returns with retryAfter enabled" , func () {
760
760
Expect (func () error {
@@ -783,7 +783,7 @@ var _ = Describe("controller", func() {
783
783
}
784
784
return nil
785
785
}, 2.0 ).Should (Succeed ())
786
- }, 2.0 )
786
+ })
787
787
})
788
788
789
789
Context ("should update prometheus metrics" , func () {
@@ -824,7 +824,7 @@ var _ = Describe("controller", func() {
824
824
By ("Removing the item from the queue" )
825
825
Eventually (queue .Len ).Should (Equal (0 ))
826
826
Eventually (func () int { return queue .NumRequeues (request ) }).Should (Equal (0 ))
827
- }, 2.0 )
827
+ })
828
828
829
829
It ("should add a reconcile time to the reconcile time histogram" , func () {
830
830
var reconcileTime dto.Metric
@@ -865,7 +865,7 @@ var _ = Describe("controller", func() {
865
865
}
866
866
return nil
867
867
}, 2.0 ).Should (Succeed ())
868
- }, 4.0 )
868
+ })
869
869
})
870
870
})
871
871
})
0 commit comments