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):
233233 if _IS_SYNC :
234234 joinall (tasks )
235235 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 ])
237237
238238 self .assertEqual (100 * [b"hello" ], results )
239239
@@ -246,7 +246,7 @@ async def test_threaded_writes(self):
246246 if _IS_SYNC :
247247 joinall (tasks )
248248 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 ])
250250
251251 f = await self .fs .get_last_version ("test" )
252252 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):
231231 if _IS_SYNC :
232232 joinall (tasks )
233233 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 ])
235235
236236 self .assertEqual (100 * [b"hello" ], results )
237237
@@ -244,7 +244,7 @@ def test_threaded_writes(self):
244244 if _IS_SYNC :
245245 joinall (tasks )
246246 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 ])
248248
249249 f = self .fs .get_last_version ("test" )
250250 self .assertEqual (f .read (), b"hello" )
You can’t perform that action at this time.
0 commit comments