|
10 | 10 | PosArgsT = TypeVarTuple("PosArgsT")
|
11 | 11 |
|
12 | 12 |
|
13 |
| -# AnyIO 4.1.0 renamed cancellable to abandon_on_cancel |
14 |
| -if "abandon_on_cancel" in inspect.getfullargspec(anyio.to_thread.run_sync).kwonlyargs: |
15 |
| - |
16 |
| - async def run_sync( |
17 |
| - func: Callable[[Unpack[PosArgsT]], T_Retval], |
18 |
| - *args: Unpack[PosArgsT], |
19 |
| - abandon_on_cancel: bool = False, |
20 |
| - limiter: Union[CapacityLimiter, None] = None, |
21 |
| - ) -> T_Retval: |
| 13 | +async def run_sync( |
| 14 | + func: Callable[[Unpack[PosArgsT]], T_Retval], |
| 15 | + *args: Unpack[PosArgsT], |
| 16 | + abandon_on_cancel: bool = False, |
| 17 | + limiter: Union[CapacityLimiter, None] = None, |
| 18 | +) -> T_Retval: |
| 19 | + # AnyIO 4.1.0 renamed cancellable to abandon_on_cancel |
| 20 | + if ( |
| 21 | + "abandon_on_cancel" |
| 22 | + in inspect.getfullargspec(anyio.to_thread.run_sync).kwonlyargs |
| 23 | + ): |
22 | 24 | return await anyio.to_thread.run_sync(
|
23 | 25 | func, *args, abandon_on_cancel=abandon_on_cancel, limiter=limiter
|
24 | 26 | )
|
25 |
| -else: |
26 |
| - |
27 |
| - async def run_sync( |
28 |
| - func: Callable[[Unpack[PosArgsT]], T_Retval], |
29 |
| - *args: Unpack[PosArgsT], |
30 |
| - abandon_on_cancel: bool = False, |
31 |
| - limiter: Union[CapacityLimiter, None] = None, |
32 |
| - ) -> T_Retval: |
| 27 | + else: |
33 | 28 | return await anyio.to_thread.run_sync(
|
34 | 29 | func, *args, cancellable=abandon_on_cancel, limiter=limiter
|
35 | 30 | )
|
0 commit comments