refactor: remove deprecated asyncio.iscoroutinefunction (#599)

Deprecated in 3.14 `asyncio.iscoroutinefunction` is getting promoted to an error in the `dask-cuda` test suite and causing `LocalCUDACluster` to fail to start.

`inspect.iscoroutinefunction` has been around since 3.5 and is the recommended switch.

xref rapidsai/dask-cuda#1629

Authors:
  - Gil Forsyth (https://github.com/gforsyth)

Approvers:
  - Tom Augspurger (https://github.com/TomAugspurger)

URL: #599

Author: gforsyth

python/ucxx/ucxx/_lib_async/listener.py

@@ -1,7 +1,8 @@
-# SPDX-FileCopyrightText: Copyright (c) 2022-2025, NVIDIA CORPORATION & AFFILIATES.
+# SPDX-FileCopyrightText: Copyright (c) 2022-2026, NVIDIA CORPORATION & AFFILIATES.
 # SPDX-License-Identifier: BSD-3-Clause
 
 import asyncio
+import inspect
 import logging
 import os
 import threading
@@ -189,7 +190,7 @@ async def _listener_handler_coroutine(
     del ctx
 
     # Finally, we call `func`
-    if asyncio.iscoroutinefunction(func):
+    if inspect.iscoroutinefunction(func):
         try:
             await func(ep)
         except Exception as e:

python/ucxx/ucxx/_lib_async/tests/conftest.py

@@ -3,6 +3,7 @@
 
 import asyncio
 import gc
+import inspect
 import os
 
 import pytest
@@ -123,7 +124,7 @@ def pytest_pyfunc_call(pyfuncitem: pytest.Function):
     else:
         reruns = 1
 
-    if asyncio.iscoroutinefunction(pyfuncitem.obj) and timeout > 0.0:
+    if inspect.iscoroutinefunction(pyfuncitem.obj) and timeout > 0.0:
 
         async def wrapped_obj(*args, **kwargs):
             for i in range(reruns):

python/ucxx/ucxx/benchmarks/send_recv.py

@@ -2,7 +2,7 @@
 # SPDX-License-Identifier: BSD-3-Clause
 
 import argparse
-import asyncio
+import inspect
 import multiprocessing as mp
 import os
 
@@ -68,7 +68,7 @@ def server(queue, args):
 
     server = _get_backend_implementation(args.backend)["server"](args, queue)
 
-    if asyncio.iscoroutinefunction(server.run):
+    if inspect.iscoroutinefunction(server.run):
         loop = get_event_loop()
         loop.run_until_complete(server.run())
     else:
@@ -85,7 +85,7 @@ def client(queue, port, server_address, args):
         args, queue, server_address, port
     )
 
-    if asyncio.iscoroutinefunction(client.run):
+    if inspect.iscoroutinefunction(client.run):
         loop = get_event_loop()
         loop.run_until_complete(client.run())
     else:

python/ucxx/ucxx/benchmarks/utils.py

@@ -2,6 +2,7 @@
 # SPDX-License-Identifier: BSD-3-Clause
 
 import asyncio
+import inspect
 import json
 import logging
 import multiprocessing as mp
@@ -256,7 +257,7 @@ async def server_handler(ep):
 
         logger.debug(f"Running worker {rank=}")
 
-        if asyncio.iscoroutinefunction(func):
+        if inspect.iscoroutinefunction(func):
             results = await func(rank, eps, args)
         else:
             results = func(rank, eps, args)