File tree Expand file tree Collapse file tree 2 files changed +5
-7
lines changed Expand file tree Collapse file tree 2 files changed +5
-7
lines changed Original file line number Diff line number Diff line change @@ -408,7 +408,7 @@ async def run(self):
408
408
finally :
409
409
self .stopped = True
410
410
411
-
411
+
412
412
class ExceptionCatchingTask (ConcurrentRunner ):
413
413
"""A Task that stores any exception encountered while running."""
414
414
@@ -425,7 +425,7 @@ async def run(self):
425
425
426
426
427
427
def create_barrier (N_TASKS , timeout : float | None = None ):
428
- return threading .Barrier (N_TASKS , timeout )
428
+ return threading .Barrier (N_TASKS , timeout = timeout )
429
429
430
430
431
431
def async_create_barrier (N_TASKS , timeout : float | None = None ):
@@ -437,5 +437,4 @@ def barrier_wait(barrier, timeout: float | None = None):
437
437
438
438
439
439
async def async_barrier_wait (barrier , timeout : float | None = None ):
440
- await asyncio .wait_for (barrier .wait (), timeout )
441
-
440
+ await asyncio .wait_for (barrier .wait (), timeout = timeout )
Original file line number Diff line number Diff line change @@ -425,7 +425,7 @@ def run(self):
425
425
426
426
427
427
def create_barrier (N_TASKS , timeout : float | None = None ):
428
- return threading .Barrier (N_TASKS , timeout )
428
+ return threading .Barrier (N_TASKS , timeout = timeout )
429
429
430
430
431
431
def create_barrier (N_TASKS , timeout : float | None = None ):
@@ -437,5 +437,4 @@ def barrier_wait(barrier, timeout: float | None = None):
437
437
438
438
439
439
def barrier_wait (barrier , timeout : float | None = None ):
440
- asyncio .wait_for (barrier .wait (), timeout )
441
-
440
+ asyncio .wait_for (barrier .wait (), timeout = timeout )
You can’t perform that action at this time.
0 commit comments