File tree Expand file tree Collapse file tree 2 files changed +5
-16
lines changed Expand file tree Collapse file tree 2 files changed +5
-16
lines changed Original file line number Diff line number Diff line change @@ -254,9 +254,7 @@ async def synchronize() -> None:
254
254
def test_warn_set_wakeup_fd_overwrite () -> None :
255
255
assert signal .set_wakeup_fd (- 1 ) == - 1
256
256
257
- async def trio_main (
258
- in_host : InHost ,
259
- ) -> str :
257
+ async def trio_main (in_host : InHost ) -> str :
260
258
return "ok"
261
259
262
260
a , b = socket .socketpair ()
@@ -298,9 +296,7 @@ async def trio_main(
298
296
signal .set_wakeup_fd (a .fileno ())
299
297
try :
300
298
301
- async def trio_check_wakeup_fd_unaltered (
302
- in_host : InHost ,
303
- ) -> str :
299
+ async def trio_check_wakeup_fd_unaltered (in_host : InHost ) -> str :
304
300
fd = signal .set_wakeup_fd (- 1 )
305
301
assert fd == a .fileno ()
306
302
signal .set_wakeup_fd (fd )
Original file line number Diff line number Diff line change @@ -2408,9 +2408,7 @@ def test_async_function_implemented_in_C() -> None:
2408
2408
# These used to crash because we'd try to mutate the coroutine object's
2409
2409
# cr_frame, but C functions don't have Python frames.
2410
2410
2411
- async def agen_fn (
2412
- record : list [str ],
2413
- ) -> AsyncIterator [None ]:
2411
+ async def agen_fn (record : list [str ]) -> AsyncIterator [None ]:
2414
2412
assert not _core .currently_ki_protected ()
2415
2413
record .append ("the generator ran" )
2416
2414
yield
@@ -2714,10 +2712,7 @@ def test_trio_run_strict_before_started(
2714
2712
else :
2715
2713
raiser_exc = ValueError ()
2716
2714
2717
- async def raiser (
2718
- * ,
2719
- task_status : _core .TaskStatus [None ],
2720
- ) -> None :
2715
+ async def raiser (* , task_status : _core .TaskStatus [None ]) -> None :
2721
2716
if raise_after_started :
2722
2717
task_status .started ()
2723
2718
raise raiser_exc
@@ -2769,9 +2764,7 @@ async def test_internal_error_old_nursery_multiple_tasks() -> None:
2769
2764
async def error_func () -> None :
2770
2765
raise ValueError
2771
2766
2772
- async def spawn_tasks_in_old_nursery (
2773
- task_status : _core .TaskStatus [None ],
2774
- ) -> None :
2767
+ async def spawn_tasks_in_old_nursery (task_status : _core .TaskStatus [None ]) -> None :
2775
2768
old_nursery = _core .current_task ().parent_nursery
2776
2769
assert old_nursery is not None
2777
2770
old_nursery .start_soon (error_func )
You can’t perform that action at this time.
0 commit comments