@@ -76,18 +76,18 @@ def after(retry_state):
76
76
77
77
await asyncio .gather (
78
78
_retryable_coroutine .retry_with (after = after )(thing1 ),
79
- _retryable_coroutine .retry_with (after = after )(thing2 ))
79
+ _retryable_coroutine .retry_with (after = after )(thing2 ))
80
80
81
81
# There's no waiting on retry, only a wait in the coroutine, so the
82
82
# executions should be interleaved.
83
- thing1_attempts = attempts [::2 ]
84
- things1 , attempt_nos1 = zip (* thing1_attempts )
85
- assert all ( thing is thing1 for thing in things1 )
83
+ even_thing_attempts = attempts [::2 ]
84
+ things , attempt_nos1 = zip (* even_thing_attempts )
85
+ assert len ( set ( things )) == 1
86
86
assert list (attempt_nos1 ) == [1 , 2 , 3 ]
87
87
88
- thing2_attempts = attempts [1 ::2 ]
89
- things2 , attempt_nos2 = zip (* thing2_attempts )
90
- assert all ( thing is thing2 for thing in things2 )
88
+ odd_thing_attempts = attempts [1 ::2 ]
89
+ things , attempt_nos2 = zip (* odd_thing_attempts )
90
+ assert len ( set ( things )) == 1
91
91
assert list (attempt_nos2 ) == [1 , 2 , 3 ]
92
92
93
93
0 commit comments