fix: harden agent invoke execution path and logger init order

Agent-Logs-Url: https://github.com/MervinPraison/PraisonAI/sessions/d404f2be-8ead-4751-95b1-4525d1d1186b

Co-authored-by: MervinPraison <454862+MervinPraison@users.noreply.github.com>

Author: Copilot

src/praisonai/praisonai/api/agent_invoke.py

@@ -6,6 +6,7 @@
 """
 
 from typing import Any, Dict, Optional, Union
+import inspect
 import logging
 
 try:
@@ -94,6 +95,12 @@ def list_registered_agents() -> list:
     return list(_agent_registry.keys())
 
 
+def _supports_async_start(agent: Any) -> bool:
+    """Return True when agent exposes a real async astart method."""
+    astart = getattr(agent, "astart", None)
+    return callable(astart) and inspect.iscoroutinefunction(astart)
+
+
 # FastAPI Router (if FastAPI is available)
 if FASTAPI_AVAILABLE and APIRouter is not None:
     router = APIRouter(prefix="/api/v1", tags=["agents"])
@@ -151,12 +158,14 @@ async def invoke_agent(
                 logger.debug(f"Agent config overrides provided: {request.agent_config}")
 
             # Invoke agent (handle both sync and async agents)
-            if hasattr(agent, 'astart'):
+            if _supports_async_start(agent):
                 # Async agent
                 result = await agent.astart(request.message)
-            else:
+            elif hasattr(agent, "start") and callable(agent.start):
                 # Sync agent (use start method)
                 result = agent.start(request.message)
+            else:
+                raise AttributeError("Agent must provide start() or async astart()")
 
             logger.info(f"Agent {agent_id} invoked successfully")
 
@@ -287,10 +296,12 @@ async def invoke_agent_standalone(
         # Invoke agent
         session_id = session_id or "default"
 
-        if hasattr(agent, 'astart'):
+        if _supports_async_start(agent):
             result = await agent.astart(message)
-        else:
+        elif hasattr(agent, "start") and callable(agent.start):
             result = agent.start(message)
+        else:
+            raise AttributeError("Agent must provide start() or async astart()")
 
         return {
             "result": str(result),
@@ -363,4 +374,4 @@ async def test_standalone():
         print(f"Agent response: {result}")
 
     # asyncio.run(test_standalone())
-    print("Agent Invoke API module loaded successfully")
+    print("Agent Invoke API module loaded successfully")

src/praisonai/praisonai/api/call.py

@@ -50,6 +50,11 @@
 
 app = FastAPI()
 
+# Set up logging
+logger = logging.getLogger(__name__)
+log_level = os.getenv("LOGLEVEL", "INFO").upper()
+logger.handlers = []
+
 # Include agent invoke router for n8n integration
 try:
     from .agent_invoke import router as agent_invoke_router
@@ -58,11 +63,6 @@
 except ImportError as e:
     logger.warning(f"Could not load agent invoke router: {e}")
 
-# Set up logging
-logger = logging.getLogger(__name__)
-log_level = os.getenv("LOGLEVEL", "INFO").upper()
-logger.handlers = []
-
 # Try to import tools from the root directory
 tools = []
 tools_path = os.path.join(os.getcwd(), 'tools.py')

src/praisonai/tests/test_n8n_agent_invoke.py

@@ -189,7 +189,7 @@ def client(self):
             app = FastAPI()
             app.include_router(router)
             return TestClient(app)
-        except ImportError:
+        except (ImportError, RuntimeError):
             pytest.skip("FastAPI test dependencies not available")
 
     def test_list_agents_endpoint(self, client):
@@ -363,4 +363,4 @@ def test_agent_invoke_smoke_test():
 if __name__ == "__main__":
     # Run smoke test when executed directly
     test_agent_invoke_smoke_test()
-    print("✅ Agent invoke API smoke test passed")
+    print("✅ Agent invoke API smoke test passed")