Fixed lints.

Author: s3rius

poetry.lock

@@ -195,4 +195,4 @@ extend-immutable-calls = ["taskiq_dependencies.Depends", "taskiq.TaskiqDepends"]
 [tool.typos.files]
 extend-exclude = [
 	"docs/README.md", # because of identifier in head section
-]
+]

pyproject.toml

@@ -109,24 +109,21 @@ async def kiq(
         self: "AsyncTaskiqDecoratedTask[_FuncParams, CoroutineType[Any, Any, _T]]",
         *args: _FuncParams.args,
         **kwargs: _FuncParams.kwargs,
-    ) -> AsyncTaskiqTask[_T]:
-        ...
+    ) -> AsyncTaskiqTask[_T]: ...
 
     @overload
     async def kiq(
         self: "AsyncTaskiqDecoratedTask[_FuncParams, Coroutine[Any, Any, _T]]",
         *args: _FuncParams.args,
         **kwargs: _FuncParams.kwargs,
-    ) -> AsyncTaskiqTask[_T]:
-        ...
+    ) -> AsyncTaskiqTask[_T]: ...
 
     @overload
     async def kiq(
         self: "AsyncTaskiqDecoratedTask[_FuncParams, _ReturnType]",
         *args: _FuncParams.args,
         **kwargs: _FuncParams.kwargs,
-    ) -> AsyncTaskiqTask[_ReturnType]:
-        ...
+    ) -> AsyncTaskiqTask[_ReturnType]: ...
 
     async def kiq(
         self,

taskiq/decor.py

@@ -34,7 +34,6 @@ async def main():
 ---
 """
 
-
 import logging
 from typing import Any, Callable, Collection, Optional
 from weakref import WeakSet as _WeakSet

taskiq/instrumentation.py

@@ -30,20 +30,17 @@ def __init__(
     @overload
     async def kiq(
         self: "CreatedSchedule[CoroutineType[Any,Any, _T]]",
-    ) -> AsyncTaskiqTask[_T]:
-        ...
+    ) -> AsyncTaskiqTask[_T]: ...
 
     @overload
     async def kiq(
         self: "CreatedSchedule[Coroutine[Any,Any, _T]]",
-    ) -> AsyncTaskiqTask[_T]:
-        ...
+    ) -> AsyncTaskiqTask[_T]: ...
 
     @overload
     async def kiq(
         self: "CreatedSchedule[_ReturnType]",
-    ) -> AsyncTaskiqTask[_ReturnType]:
-        ...
+    ) -> AsyncTaskiqTask[_ReturnType]: ...
 
     async def kiq(self) -> Any:
         """Kick the task as if you were not scheduling it."""

taskiq/scheduler/created_schedule.py

@@ -14,8 +14,7 @@ async def test_successful() -> None:
     scheduler_task = asyncio.create_task(run_scheduler_task(scheduler))
 
     @broker.task(schedule=[{"time": datetime.now(timezone.utc) - timedelta(seconds=1)}])
-    def _() -> None:
-        ...
+    def _() -> None: ...
 
     msg = await asyncio.wait_for(broker.queue.get(), 0.3)
     assert msg
@@ -28,8 +27,7 @@ async def test_cancelation() -> None:
     scheduler = TaskiqScheduler(broker, sources=[LabelScheduleSource(broker)])
 
     @broker.task(schedule=[{"time": datetime.now(timezone.utc)}])
-    def _() -> None:
-        ...
+    def _() -> None: ...
 
     scheduler_task = asyncio.create_task(run_scheduler_task(scheduler))