fix: warning about asyncio.iscoroutinefunction usage

Author: danfimov

pyproject.toml

@@ -190,7 +190,6 @@ line-length = 88
 	"S311",   # Standard pseudo-random generators are not suitable for security/cryptographic purposes
 	"D101",   # Missing docstring in public class
 	"D102",   # Missing docstring in public method
-	"PLR2004",  # Magic value
 ]
 "docs/examples/*" = [
 	"D103",  # Missing docstring in public function

taskiq/receiver/receiver.py

@@ -2,6 +2,7 @@
 import contextvars
 import functools
 import inspect
+import sys
 from collections.abc import Callable
 from concurrent.futures import Executor
 from logging import getLogger
@@ -23,6 +24,7 @@
 from taskiq.utils import maybe_awaitable
 
 logger = getLogger(__name__)
+PY_VERSION = sys.version_info
 QUEUE_DONE = b"-1"
 
 
@@ -224,6 +226,11 @@ async def run_task(  # noqa: C901, PLR0912, PLR0915
         # Start a timer.
         start_time = time()
 
+        check_coroutine_func = (
+            asyncio.iscoroutinefunction
+            if PY_VERSION <= (3, 13)
+            else inspect.iscoroutinefunction
+        )
         try:
             # We put kwargs resolving here,
             # to be able to catch any exception (for example ),
@@ -234,7 +241,7 @@ async def run_task(  # noqa: C901, PLR0912, PLR0915
             kwargs.update(message.kwargs)
             is_coroutine = True
             # If the function is a coroutine, we await it.
-            if asyncio.iscoroutinefunction(target):
+            if check_coroutine_func(target):
                 target_future = target(*message.args, **kwargs)
             else:
                 is_coroutine = False