File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -348,7 +348,10 @@ def test_create_snapshot(self):
348
348
349
349
# There is no GET method for snapshot, so check existence using
350
350
# list
351
- retry = RetryResult (lambda result : result , max_tries = 4 )
351
+ def retry_predicate (result ):
352
+ return len (result ) > len (before_snapshots )
353
+
354
+ retry = RetryResult (retry_predicate , max_tries = 5 )
352
355
after_snapshots = retry (_consume_snapshots )(Config .CLIENT )
353
356
self .assertEqual (len (before_snapshots ) + 1 , len (after_snapshots ))
354
357
@@ -361,7 +364,6 @@ def full_name(obj):
361
364
with self .assertRaises (Conflict ):
362
365
snapshot .create ()
363
366
364
-
365
367
def test_seek (self ):
366
368
TOPIC_NAME = 'seek-e2e' + unique_resource_id ('-' )
367
369
topic = Config .CLIENT .topic (TOPIC_NAME ,
You can’t perform that action at this time.
0 commit comments