@@ -26,9 +26,6 @@ def get_error_types(eg):
26
26
27
27
class TestTaskGroup (unittest .IsolatedAsyncioTestCase ):
28
28
29
- async def asyncSetUp (self ):
30
- self .loop = asyncio .get_event_loop ()
31
-
32
29
async def test_taskgroup_01 (self ):
33
30
34
31
async def foo1 ():
@@ -115,7 +112,7 @@ async def runner():
115
112
NUM += 10
116
113
117
114
with self .assertRaises (ExceptionGroup ) as cm :
118
- await self . loop .create_task (runner ())
115
+ await asyncio .create_task (runner ())
119
116
120
117
self .assertEqual (get_error_types (cm .exception ), {ZeroDivisionError })
121
118
@@ -161,7 +158,7 @@ async def runner():
161
158
# The 3 foo1 sub tasks can be racy when the host is busy - if the
162
159
# cancellation happens in the middle, we'll see partial sub errors here
163
160
with self .assertRaises (ExceptionGroup ) as cm :
164
- await self . loop .create_task (runner ())
161
+ await asyncio .create_task (runner ())
165
162
166
163
self .assertEqual (get_error_types (cm .exception ), {ZeroDivisionError })
167
164
self .assertEqual (NUM , 0 )
@@ -185,7 +182,7 @@ async def runner():
185
182
for _ in range (5 ):
186
183
g .create_task (foo ())
187
184
188
- r = self . loop .create_task (runner ())
185
+ r = asyncio .create_task (runner ())
189
186
await asyncio .sleep (0.1 )
190
187
191
188
self .assertFalse (r .done ())
@@ -219,7 +216,7 @@ async def runner():
219
216
NUM += 10
220
217
raise
221
218
222
- r = self . loop .create_task (runner ())
219
+ r = asyncio .create_task (runner ())
223
220
await asyncio .sleep (0.1 )
224
221
225
222
self .assertFalse (r .done ())
@@ -245,7 +242,7 @@ async def runner():
245
242
except asyncio .CancelledError :
246
243
raise
247
244
248
- r = self . loop .create_task (runner ())
245
+ r = asyncio .create_task (runner ())
249
246
await asyncio .sleep (0.1 )
250
247
251
248
self .assertFalse (r .done ())
@@ -329,7 +326,7 @@ async def runner():
329
326
except asyncio .CancelledError :
330
327
raise
331
328
332
- r = self . loop .create_task (runner ())
329
+ r = asyncio .create_task (runner ())
333
330
await asyncio .sleep (0.1 )
334
331
335
332
self .assertFalse (r .done ())
@@ -356,7 +353,7 @@ async def runner():
356
353
except asyncio .CancelledError :
357
354
raise
358
355
359
- r = self . loop .create_task (runner ())
356
+ r = asyncio .create_task (runner ())
360
357
await asyncio .sleep (0.1 )
361
358
362
359
self .assertFalse (r .done ())
@@ -377,7 +374,7 @@ async def runner():
377
374
async with taskgroups .TaskGroup (name = 'g2' ) as g2 :
378
375
g2 .create_task (crash_after (0.2 ))
379
376
380
- r = self . loop .create_task (runner ())
377
+ r = asyncio .create_task (runner ())
381
378
with self .assertRaises (ExceptionGroup ) as cm :
382
379
await r
383
380
@@ -396,7 +393,7 @@ async def runner():
396
393
async with taskgroups .TaskGroup (name = 'g2' ) as g2 :
397
394
g2 .create_task (crash_after (0.1 ))
398
395
399
- r = self . loop .create_task (runner ())
396
+ r = asyncio .create_task (runner ())
400
397
with self .assertRaises (ExceptionGroup ) as cm :
401
398
await r
402
399
@@ -419,7 +416,7 @@ async def runner():
419
416
await asyncio .sleep (0.5 )
420
417
raise
421
418
422
- r = self . loop .create_task (runner ())
419
+ r = asyncio .create_task (runner ())
423
420
await asyncio .sleep (0.1 )
424
421
425
422
self .assertFalse (r .done ())
@@ -443,10 +440,10 @@ async def nested_runner():
443
440
raise
444
441
445
442
async def runner ():
446
- t = self . loop .create_task (nested_runner ())
443
+ t = asyncio .create_task (nested_runner ())
447
444
await t
448
445
449
- r = self . loop .create_task (runner ())
446
+ r = asyncio .create_task (runner ())
450
447
await asyncio .sleep (0.1 )
451
448
452
449
self .assertFalse (r .done ())
@@ -466,7 +463,7 @@ async def runner():
466
463
NUM += 10
467
464
raise
468
465
469
- r = self . loop .create_task (runner ())
466
+ r = asyncio .create_task (runner ())
470
467
await asyncio .sleep (0.1 )
471
468
472
469
self .assertFalse (r .done ())
@@ -490,7 +487,7 @@ async def runner():
490
487
# this weird case.
491
488
raise MyExc
492
489
493
- r = self . loop .create_task (runner ())
490
+ r = asyncio .create_task (runner ())
494
491
await asyncio .sleep (0.1 )
495
492
496
493
self .assertFalse (r .done ())
@@ -521,7 +518,7 @@ async def runner():
521
518
g .create_task (crash_soon ())
522
519
await nested ()
523
520
524
- r = self . loop .create_task (runner ())
521
+ r = asyncio .create_task (runner ())
525
522
try :
526
523
await r
527
524
except ExceptionGroup as t :
@@ -634,7 +631,7 @@ async def runner():
634
631
g .create_task (foo1 ())
635
632
g .create_task (foo2 ())
636
633
637
- r = self . loop .create_task (runner ())
634
+ r = asyncio .create_task (runner ())
638
635
await asyncio .sleep (0.05 )
639
636
r .cancel ()
640
637
0 commit comments