fix: ruff,pyright errors

ruff.toml

@@ -31,6 +31,7 @@ fixable = [
     "PIE808",  # unnecessary-range-start
     "RUF020",  # never-union 
     "NPY201",  # numpy2-deprecation
+    "PT",
 ]
 ignore = [
     "TD",
@@ -87,6 +88,8 @@ ignore = [
     # pydocstyle # TODO
     "D100", # undocumented-public-module
     "D104", # undocumented-public-package
+    # async
+    "ASYNC109", # async-function-with-timeout
 ]
 
 [lint.per-file-ignores]

src/async_wrapper/convert/_async.py

@@ -1,3 +1,5 @@
+# FIXME: pyright v1.1.379 && pylance v2024.8.2
+# pyright: reportUnnecessaryTypeIgnoreComment=false
 from __future__ import annotations
 
 from functools import cached_property, partial, wraps

src/async_wrapper/convert/main.py

@@ -1,3 +1,5 @@
+# FIXME: pyright v1.1.379 && pylance v2024.8.2
+# pyright: reportUnnecessaryTypeIgnoreComment=false
 from __future__ import annotations
 
 from inspect import iscoroutinefunction

tests/convert/test_async.py

@@ -62,7 +62,7 @@ async def engine(
         await engine.dispose()
 
 
-@pytest.fixture()
+@pytest.fixture
 async def session(engine: AsyncEngine) -> AsyncGenerator[AsyncSession, None]:
     async with AsyncSession(engine) as session:
         yield session

tests/convert/test_sync.py

@@ -5,6 +5,7 @@
 
 import anyio
 import pytest
+from anyio.lowlevel import checkpoint
 from sniffio import current_async_library
 from typing_extensions import TypeVar
 
@@ -50,7 +51,7 @@ def test_toggle(self, x: int):
             sample(x, self.epsilon)
         assert self.epsilon * x < timer.term < self.epsilon * x + self.epsilon
 
-    @pytest.mark.anyio()
+    @pytest.mark.anyio
     @pytest.mark.parametrize("x", range(1, 4))
     async def test_async_to_sync_in_async(self, x: int):
         backend = current_async_library()
@@ -72,7 +73,7 @@ def __await__(self) -> Generator[Any, None, ValueT]:
 
 def sample_coroutine(value: ValueT) -> Coroutine[Any, Any, ValueT]:
     async def inner() -> ValueT:
-        await anyio.sleep(0)
+        await checkpoint()
         return value
 
     return inner()

tests/convert/test_toggle.py

@@ -3,8 +3,8 @@
 from collections.abc import Callable
 from typing import Any
 
-import anyio
 import pytest
+from anyio.lowlevel import checkpoint
 
 from async_wrapper import toggle_func
 
@@ -14,7 +14,7 @@ def sample_sync_func(x: Any) -> Any:
 
 
 async def sample_async_func(x: Any) -> Any:
-    await anyio.sleep(0)
+    await checkpoint()
     return x
 
 

tests/task_group/test_task_group.py

@@ -12,7 +12,7 @@
 from async_wrapper.task_group import SoonValue
 
 
-@pytest.mark.anyio()
+@pytest.mark.anyio
 class TestTaskGroupWrapper:
     epsilon: Final[float] = 0.1
 

tests/task_group/test_value.py

@@ -30,7 +30,7 @@ def test_value_setattr(x: int):
     assert maybe == x
 
 
-@pytest.mark.anyio()
+@pytest.mark.anyio
 @pytest.mark.parametrize("x", range(4))
 async def test_value_setattr_async(x: int):
     value: SoonValue[Any] = SoonValue()

tests/test_pipe.py

@@ -9,6 +9,7 @@
 
 import anyio
 import pytest
+from anyio.lowlevel import checkpoint
 from typing_extensions import TypeVar, override
 
 from .base import Timer
@@ -41,12 +42,12 @@ def is_disposed(self) -> bool:
         return self.disposed
 
     async def next(self, value: Any) -> Any:
-        await anyio.sleep(0)
+        await checkpoint()
         self.value = value
         return value
 
     async def dispose(self) -> Any:
-        await anyio.sleep(0)
+        await checkpoint()
         self.disposed = True
 
         if self._dispose is not None:
@@ -121,25 +122,25 @@ def subscribable_type(request: pytest.FixtureRequest) -> type[Subscribable[Any,
 
 
 async def as_tuple(value: ValueT) -> tuple[ValueT]:
-    await anyio.sleep(0)
+    await checkpoint()
     return (value,)
 
 
 async def return_self(value: ValueT) -> ValueT:
-    await anyio.sleep(0)
+    await checkpoint()
     return value
 
 
 def use_value():
     result = None
 
     async def getter() -> Any:
-        await anyio.sleep(0)
+        await checkpoint()
         return result
 
     async def setter(value: Any) -> None:
         nonlocal result
-        await anyio.sleep(0)
+        await checkpoint()
         result = value
 
     return getter, setter
@@ -154,7 +155,7 @@ def check_hit() -> None:
 
     async def hit(value: Any) -> None:  # noqa: ARG001
         nonlocal flag
-        await anyio.sleep(0)
+        await checkpoint()
         flag = True
 
     pipe = Pipe(hit)
@@ -213,7 +214,7 @@ async def test_subscribe_many(x: int, subscribable_type: type[Subscribable[Any,
 
     async def hit(value: Any, index: int) -> None:
         nonlocal check
-        await anyio.sleep(0)
+        await checkpoint()
         check[index] = value
 
     pipe: Subscribable[int, tuple[Any, ...]] = _construct_subcribable(
@@ -304,7 +305,7 @@ async def test_dispose(subscribable_type: type[Subscribable[Any, Any]]):
 
     async def hit() -> None:
         nonlocal flag
-        await anyio.sleep(0)
+        await checkpoint()
         flag = True
 
     pipe: Subscribable[Any, Any]
@@ -329,7 +330,7 @@ async def test_dispose_many(subscribable_type: type[Subscribable[Any, Any]]):
 
     async def hit(index: int) -> None:
         nonlocal check
-        await anyio.sleep(0)
+        await checkpoint()
         check[index] = True
 
     pipe: Subscribable[Any, Any] = _construct_subcribable(
@@ -369,7 +370,7 @@ async def test_pipe_dispose_only_once():
 
     async def hit() -> None:
         nonlocal count
-        await anyio.sleep(0)
+        await checkpoint()
         count += 1
 
     pipe = Pipe(return_self, dispose=hit)
@@ -384,7 +385,7 @@ async def test_do_not_dispose(subscribable_type: type[Subscribable[Any, Any]]):
 
     async def hit() -> None:
         nonlocal flag
-        await anyio.sleep(0)
+        await checkpoint()
         flag = True
 
     pipe: Subscribable[int, int] = _construct_subcribable(
@@ -467,7 +468,7 @@ async def test_pipe_next_after_disposed():
 
     async def hit(value: Any) -> None:  # noqa: ARG001
         nonlocal flag
-        await anyio.sleep(0)
+        await checkpoint()
         flag = True
 
     pipe = Pipe(hit)