Skip to content

Commit 0b851a7

Browse files
committed
avoid setting the policy in test_asyngen
1 parent b4d6597 commit 0b851a7

1 file changed

Lines changed: 7 additions & 4 deletions

File tree

‎Lib/test/test_asyncgen.py‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2170,6 +2170,9 @@ async def agenfn():
21702170
gc_collect() # does not warn unawaited
21712171

21722172

2173+
_asyncio_run = functools.partial(asyncio.run, loop_factory=asyncio.EventLoop)
2174+
2175+
21732176
@requires_working_socket()
21742177
class AsyncGenAsyncioRunTestCase(unittest.TestCase):
21752178
def test_async_gen_asyncio_shutdown_02(self):
@@ -2190,7 +2193,7 @@ async def main():
21902193
async for i in it:
21912194
break
21922195

2193-
asyncio.run(main())
2196+
_asyncio_run(main())
21942197

21952198
self.assertEqual(messages, [])
21962199

@@ -2215,7 +2218,7 @@ async def main():
22152218
async for i in it:
22162219
break
22172220

2218-
asyncio.run(main())
2221+
_asyncio_run(main())
22192222

22202223
message, = messages
22212224
self.assertEqual(message['asyncgen'], it)
@@ -2244,7 +2247,7 @@ async def main():
22442247
break
22452248
gc_collect()
22462249

2247-
asyncio.run(main())
2250+
_asyncio_run(main())
22482251

22492252
message, = messages
22502253
self.assertIsInstance(message['exception'], ZeroDivisionError)
@@ -2271,7 +2274,7 @@ async def main():
22712274
async for i in async_iterate():
22722275
break
22732276

2274-
asyncio.run(main())
2277+
_asyncio_run(main())
22752278

22762279
self.assertEqual([], messages)
22772280
gc_collect()

0 commit comments

Comments
 (0)