@@ -230,6 +230,7 @@ def test_crud_tags(self, ec2_client, simple_vpc):
230
230
resource = k8s .get_resource (ref )
231
231
assert len (resource ["spec" ]["tags" ]) == 0
232
232
233
+ k8s .wait_on_condition (ref , "ACK.ResourceSynced" , "True" , wait_periods = 5 )
233
234
# Delete k8s resource
234
235
_ , deleted = k8s .delete_custom_resource (ref )
235
236
assert deleted is True
@@ -282,7 +283,7 @@ def test_update_disallow_default_security_group_rule(self, ec2_client, simple_vp
282
283
}
283
284
k8s .patch_custom_resource (ref , updates )
284
285
time .sleep (MODIFY_WAIT_AFTER_SECONDS )
285
-
286
+ k8s . wait_on_condition ( ref , "ACK.ResourceSynced" , "True" , wait_periods = 5 )
286
287
# Make sure default security group rule is deleted
287
288
assert not contains_default_sg_rule (ec2_client , resource_id )
288
289
@@ -480,6 +481,7 @@ def test_vpc_updation_multiple_cidr(self,ec2_client):
480
481
k8s .patch_custom_resource (ref , updates )
481
482
time .sleep (MODIFY_WAIT_AFTER_SECONDS )
482
483
484
+ k8s .wait_on_condition (ref , "ACK.ResourceSynced" , "True" , wait_periods = 5 )
483
485
# Re-Validate CIDR Blocks State
484
486
vpc = ec2_validator .get_vpc (resource_id )
485
487
assert vpc ['CidrBlockAssociationSet' ][0 ]['CidrBlockState' ]['State' ] == "associated"
0 commit comments