Uses iscoroutinefunction from inspect module

Author: jairhenrique

instrumentation/opentelemetry-instrumentation-aiokafka/src/opentelemetry/instrumentation/aiokafka/__init__.py

@@ -95,7 +95,7 @@ async def produce():
 
 from __future__ import annotations
 
-from asyncio import iscoroutinefunction
+from inspect import iscoroutinefunction
 from typing import TYPE_CHECKING, Collection
 
 import aiokafka

instrumentation/opentelemetry-instrumentation-aiopg/src/opentelemetry/instrumentation/aiopg/aiopg_integration.py

@@ -1,4 +1,4 @@
-import asyncio
+import inspect
 import typing
 from collections.abc import Coroutine
 
@@ -197,7 +197,7 @@ async def __aenter__(self):
 
     async def __aexit__(self, exc_type, exc, t_b):
         try:
-            if asyncio.iscoroutinefunction(self._obj.close):
+            if inspect.iscoroutinefunction(self._obj.close):
                 await self._obj.close()
             else:
                 self._obj.close()

instrumentation/opentelemetry-instrumentation-httpx/src/opentelemetry/instrumentation/httpx/__init__.py

@@ -225,8 +225,8 @@ async def async_response_hook(span, request, response):
 
 import logging
 import typing
-from asyncio import iscoroutinefunction
 from functools import partial
+from inspect import iscoroutinefunction
 from timeit import default_timer
 from types import TracebackType
 

instrumentation/opentelemetry-instrumentation-httpx/tests/test_httpx_integration.py

@@ -16,6 +16,7 @@
 
 import abc
 import asyncio
+import inspect
 import typing
 from unittest import mock
 
@@ -1086,7 +1087,7 @@ def test_custom_tracer_provider(self):
         def test_response_hook(self):
             response_hook_key = (
                 "async_response_hook"
-                if asyncio.iscoroutinefunction(self.response_hook)
+                if inspect.iscoroutinefunction(self.response_hook)
                 else "response_hook"
             )
             response_hook_kwargs = {response_hook_key: self.response_hook}
@@ -1133,7 +1134,7 @@ def test_response_hook_sync_async_kwargs(self):
         def test_request_hook(self):
             request_hook_key = (
                 "async_request_hook"
-                if asyncio.iscoroutinefunction(self.request_hook)
+                if inspect.iscoroutinefunction(self.request_hook)
                 else "request_hook"
             )
             request_hook_kwargs = {request_hook_key: self.request_hook}