@@ -907,6 +907,8 @@ var _ = g.Describe("deploymentconfigs", func() {
907
907
// FIXME: remove when tests are migrated to the new client
908
908
// (the old one incorrectly translates nil into an empty array)
909
909
dc .Spec .Triggers = append (dc .Spec .Triggers , deployapi.DeploymentTriggerPolicy {Type : deployapi .DeploymentTriggerOnConfigChange })
910
+ // This is the last place we can safely say that the time was taken before replicas became ready
911
+ startTime := time .Now ()
910
912
dc , err = oc .Client ().DeploymentConfigs (namespace ).Create (dc )
911
913
o .Expect (err ).NotTo (o .HaveOccurred ())
912
914
@@ -937,7 +939,7 @@ var _ = g.Describe("deploymentconfigs", func() {
937
939
938
940
g .By ("waiting for the deployment to finish" )
939
941
rc1 , err = waitForRCModification (oc , namespace , rc1 .Name ,
940
- deploymentChangeTimeout + time .Duration (dc .Spec .MinReadySeconds )* time .Second ,
942
+ deploymentRunTimeout + time .Duration (dc .Spec .MinReadySeconds )* time .Second ,
941
943
rc1 .GetResourceVersion (), func (rc * kapiv1.ReplicationController ) (bool , error ) {
942
944
if rc .Status .AvailableReplicas == dc .Spec .Replicas {
943
945
return true , nil
@@ -952,6 +954,8 @@ var _ = g.Describe("deploymentconfigs", func() {
952
954
// We need to log here to have a timestamp to compare with master logs if something goes wrong
953
955
e2e .Logf ("Finished waiting for deployment." )
954
956
o .Expect (err ).NotTo (o .HaveOccurred ())
957
+ o .Expect (time .Since (startTime )).To (o .BeNumerically (">=" , time .Duration (dc .Spec .MinReadySeconds )* time .Second ),
958
+ "Deployment shall not finish before MinReadySeconds elapse." )
955
959
o .Expect (rc1 .Status .AvailableReplicas ).To (o .Equal (dc .Spec .Replicas ))
956
960
// Deployment status can't be updated yet but should be right after
957
961
o .Expect (deployutil .DeploymentStatusFor (rc1 )).To (o .Equal (deployapi .DeploymentStatusRunning ))
0 commit comments