File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -233,7 +233,7 @@ async def test_threaded_reads(self):
233
233
if _IS_SYNC :
234
234
joinall (tasks )
235
235
else :
236
- await asyncio .wait ([t .task for t in tasks ])
236
+ await asyncio .wait ([t .task for t in tasks if t . task is not None ])
237
237
238
238
self .assertEqual (100 * [b"hello" ], results )
239
239
@@ -246,7 +246,7 @@ async def test_threaded_writes(self):
246
246
if _IS_SYNC :
247
247
joinall (tasks )
248
248
else :
249
- await asyncio .wait ([t .task for t in tasks ])
249
+ await asyncio .wait ([t .task for t in tasks if t . task is not None ])
250
250
251
251
f = await self .fs .get_last_version ("test" )
252
252
self .assertEqual (await f .read (), b"hello" )
Original file line number Diff line number Diff line change @@ -231,7 +231,7 @@ def test_threaded_reads(self):
231
231
if _IS_SYNC :
232
232
joinall (tasks )
233
233
else :
234
- asyncio .wait ([t .task for t in tasks ])
234
+ asyncio .wait ([t .task for t in tasks if t . task is not None ])
235
235
236
236
self .assertEqual (100 * [b"hello" ], results )
237
237
@@ -244,7 +244,7 @@ def test_threaded_writes(self):
244
244
if _IS_SYNC :
245
245
joinall (tasks )
246
246
else :
247
- asyncio .wait ([t .task for t in tasks ])
247
+ asyncio .wait ([t .task for t in tasks if t . task is not None ])
248
248
249
249
f = self .fs .get_last_version ("test" )
250
250
self .assertEqual (f .read (), b"hello" )
You can’t perform that action at this time.
0 commit comments