remove deprecated asyncio.iscoroutine* usage

Author: masenf

reflex/state.py

@@ -246,7 +246,7 @@ def __call__(self, *args: Any) -> EventSpec:
                 msg = f"Variable `{args[0]}` cannot be set on `{self.state_cls.get_full_name()}`"
                 raise AttributeError(msg)
 
-            if asyncio.iscoroutinefunction(handler.fn):
+            if inspect.iscoroutinefunction(handler.fn):
                 msg = f"Setter for {args[0]} is async, which is not supported."
                 raise NotImplementedError(msg)
 
@@ -287,7 +287,7 @@ async def _resolve_delta(delta: Delta) -> Delta:
     tasks = {}
     for state_name, state_delta in delta.items():
         for var_name, value in state_delta.items():
-            if asyncio.iscoroutine(value):
+            if inspect.iscoroutine(value):
                 tasks[state_name, var_name] = asyncio.create_task(
                     value,
                     name=f"reflex_resolve_delta|{state_name}|{var_name}|{time.time()}",
@@ -1733,7 +1733,7 @@ def _is_valid_type(events: Any) -> bool:
         except TypeError:
             pass
 
-        coroutines = [e for e in events if asyncio.iscoroutine(e)]
+        coroutines = [e for e in events if inspect.iscoroutine(e)]
 
         for coroutine in coroutines:
             coroutine_name = coroutine.__qualname__
@@ -1895,7 +1895,7 @@ async def _process_event(
         # Wrap the function in a try/except block.
         try:
             # Handle async functions.
-            if asyncio.iscoroutinefunction(fn.func):
+            if inspect.iscoroutinefunction(fn.func):
                 events = await fn(**payload)
 
             # Handle regular functions.

reflex/utils/misc.py

@@ -2,6 +2,7 @@
 
 import asyncio
 import contextlib
+import inspect
 import sys
 import threading
 from collections.abc import Callable
@@ -62,7 +63,7 @@ async def run_in_thread(func: Callable) -> Any:
     Returns:
         Any: The return value of the function.
     """
-    if asyncio.coroutines.iscoroutinefunction(func):
+    if inspect.iscoroutinefunction(func):
         msg = "func must be a non-async function"
         raise ValueError(msg)
     return await asyncio.get_event_loop().run_in_executor(None, func)

reflex/utils/monitoring.py

@@ -1,6 +1,5 @@
 """PyLeak integration for monitoring event loop blocking and resource leaks in Reflex applications."""
 
-import asyncio
 import contextlib
 import functools
 import inspect
@@ -154,7 +153,7 @@ async def async_gen_wrapper(*args, **kwargs):
 
         return async_gen_wrapper
 
-    if asyncio.iscoroutinefunction(func):
+    if inspect.iscoroutinefunction(func):
 
         @functools.wraps(func)
         async def async_wrapper(*args, **kwargs):