File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change 46
46
- python : " 3.8"
47
47
runs_on : windows-2019
48
48
- python : " 3.9"
49
- runs_on : macos-10.15
49
+ runs_on : macos-11
50
50
- python : " 3.11"
51
51
52
52
steps :
Original file line number Diff line number Diff line change @@ -395,13 +395,16 @@ def test_dir(self):
395
395
def test_wait_for_send (self ):
396
396
view = self .client [- 1 ]
397
397
view .track = True
398
+
398
399
with pytest .raises (TimeoutError ):
399
400
# this test can fail if the send happens too quickly
400
401
# e.g. the IO thread takes control for too long,
401
402
# so run the test a few times
402
- for i in range (10 ):
403
+ for i in range (3 ):
403
404
if i > 0 :
404
405
print ("Retrying test_wait_for_send" )
406
+ # inject delay in io loop so send doesn't complete immediately
407
+ self .client ._io_loop .add_callback (lambda : time .sleep (0.5 ))
405
408
data = os .urandom (10 * 1024 * 1024 )
406
409
ar = view .apply_async (lambda x : x , data )
407
410
ar .wait_for_send (0 )
You can’t perform that action at this time.
0 commit comments