@@ -210,7 +210,7 @@ var _ = Describe("controller", func() {
210
210
}()
211
211
212
212
<- sourceSynced
213
- }, 10.0 )
213
+ })
214
214
215
215
It ("should process events from source.Channel" , func () {
216
216
// channel to be closed when event is processed
@@ -521,8 +521,8 @@ var _ = Describe("controller", func() {
521
521
522
522
By ("Removing the item from the queue" )
523
523
Eventually (queue .Len ).Should (Equal (0 ))
524
- Eventually (func () int { return queue .NumRequeues (request ) }).Should (Equal (0 ))
525
- }, 1.0 )
524
+ Eventually (func () int { return queue .NumRequeues (request ) }, 1.0 ).Should (Equal (0 ))
525
+ })
526
526
527
527
// TODO(directxman12): we should ensure that backoff occurrs with error requeue
528
528
@@ -698,7 +698,7 @@ var _ = Describe("controller", func() {
698
698
}
699
699
return nil
700
700
}, 2.0 ).Should (Succeed ())
701
- }, 2.0 )
701
+ })
702
702
703
703
It ("should get updated on reconcile errors" , func () {
704
704
Expect (func () error {
@@ -727,7 +727,7 @@ var _ = Describe("controller", func() {
727
727
}
728
728
return nil
729
729
}, 2.0 ).Should (Succeed ())
730
- }, 2.0 )
730
+ })
731
731
732
732
It ("should get updated when reconcile returns with retry enabled" , func () {
733
733
Expect (func () error {
@@ -757,7 +757,7 @@ var _ = Describe("controller", func() {
757
757
}
758
758
return nil
759
759
}, 2.0 ).Should (Succeed ())
760
- }, 2.0 )
760
+ })
761
761
762
762
It ("should get updated when reconcile returns with retryAfter enabled" , func () {
763
763
Expect (func () error {
@@ -786,7 +786,7 @@ var _ = Describe("controller", func() {
786
786
}
787
787
return nil
788
788
}, 2.0 ).Should (Succeed ())
789
- }, 2.0 )
789
+ })
790
790
})
791
791
792
792
Context ("should update prometheus metrics" , func () {
@@ -827,7 +827,7 @@ var _ = Describe("controller", func() {
827
827
By ("Removing the item from the queue" )
828
828
Eventually (queue .Len ).Should (Equal (0 ))
829
829
Eventually (func () int { return queue .NumRequeues (request ) }).Should (Equal (0 ))
830
- }, 2.0 )
830
+ })
831
831
832
832
It ("should add a reconcile time to the reconcile time histogram" , func () {
833
833
var reconcileTime dto.Metric
@@ -868,7 +868,7 @@ var _ = Describe("controller", func() {
868
868
}
869
869
return nil
870
870
}, 2.0 ).Should (Succeed ())
871
- }, 4.0 )
871
+ })
872
872
})
873
873
})
874
874
})
0 commit comments