@@ -15,8 +15,6 @@ def bytes_to_string(data: bytes):
15
15
16
16
17
17
class NestedAsyncIO :
18
- """Patch asyncio to allow nested event loops."""
19
-
20
18
__slots__ = [
21
19
"_loop" ,
22
20
"orig_run" ,
@@ -104,20 +102,13 @@ def _get_event_loop(stacklevel=3):
104
102
if sys .version_info < (3 , 7 , 0 ):
105
103
asyncio .tasks ._current_tasks = asyncio .tasks .Task ._current_tasks
106
104
asyncio .all_tasks = asyncio .tasks .Task .all_tasks
107
- elif sys .version_info >= (3 , 9 , 0 ) and sys . version_info < ( 3 , 12 , 0 ) :
105
+ elif sys .version_info >= (3 , 9 , 0 ):
108
106
self .orig_get_loops = {
109
107
"events__get_event_loop" : events ._get_event_loop ,
110
108
"events_get_event_loop" : events .get_event_loop ,
111
109
"asyncio_get_event_loop" : asyncio .get_event_loop ,
112
110
}
113
111
events ._get_event_loop = events .get_event_loop = asyncio .get_event_loop = _get_event_loop
114
- elif sys .version_info >= (3 , 12 , 0 ):
115
- self .orig_get_loops = {
116
- "events__get_event_loop" : events .get_event_loop ,
117
- "events_get_event_loop" : events .get_event_loop ,
118
- "asyncio_get_event_loop" : asyncio .get_event_loop ,
119
- }
120
- events ._get_event_loop = events .get_event_loop = asyncio .get_event_loop = _get_event_loop
121
112
self .orig_run = asyncio .run
122
113
asyncio .run = run
123
114
asyncio ._nest_patched = True
@@ -315,6 +306,6 @@ def patch_tornado(self):
315
306
316
307
def unpatch_tornado (self ):
317
308
if self .orig_tc :
318
- import tornado .concurrent as tc # noqa
309
+ import tornado .concurrent as tc
319
310
320
311
tc .Future = self .orig_tc
0 commit comments