fix(deprecation): iscoroutinefunction from inspect

Author: dineshpinto

src/flare_ai_kit/consensus/communication/channels.py

@@ -1,6 +1,7 @@
 """Implementation of communication channels for inter-agent communication."""
 
 import asyncio
+import inspect
 import time
 import uuid
 from collections import defaultdict
@@ -89,7 +90,7 @@ async def publish_event(self, event_type: str, data: dict[str, Any]) -> None:
         if handlers:
             tasks: list[Any] = []
             for handler in handlers.values():
-                if asyncio.iscoroutinefunction(handler):
+                if inspect.iscoroutinefunction(handler):
                     tasks.append(handler(data))
                 else:
                     # For non-async handlers, run in thread pool

src/flare_ai_kit/consensus/coordinator/simple.py

@@ -1,6 +1,7 @@
 """An enhanced implementation of the Coordinator interface."""
 
 import asyncio
+import inspect
 from dataclasses import dataclass, field
 from typing import Any
 
@@ -74,14 +75,14 @@ async def start_agents(self) -> None:
         """Starts all agents that define a `start()` coroutine."""
         for agent in self.agents.values():
             agent_start = getattr(agent.agent, "start", None)
-            if agent_start is not None and asyncio.iscoroutinefunction(agent_start):
+            if agent_start is not None and inspect.iscoroutinefunction(agent_start):
                 await agent_start()
 
     async def stop_agents(self) -> None:
         """Stops all agents that define a `stop()` coroutine."""
         for agent in self.agents.values():
             agent_stop = getattr(agent.agent, "stop", None)
-            if agent_stop is not None and asyncio.iscoroutinefunction(agent_stop):
+            if agent_stop is not None and inspect.iscoroutinefunction(agent_stop):
                 await agent_stop()
 
     def monitor_agents(self) -> list[dict[str, str | Any]]: