feat: deprecate Runtime.instance() in favour of GlobalRuntime.instance()

ak-py/pyproject.toml

@@ -13,6 +13,7 @@ authors = [
     { name = "Yaala Labs", email = "[email protected]" }
 ]
 dependencies = [
+    "deprecated>=1.3.1",
     "pydantic>=2.11.7",
     "pydantic-settings>=2.10.1",
     "pyyaml>=6.0.2",

ak-py/src/agentkernel/a2a/a2a.py

@@ -9,7 +9,7 @@
 from a2a.utils import new_agent_text_message
 from a2a.utils.errors import ServerError
 
-from ..core import Agent, AgentService, Runtime
+from ..core import Agent, AgentService, GlobalRuntime
 from ..core.config import AKConfig
 
 
@@ -69,7 +69,7 @@ def _build(cls):
             return
         if not AKConfig.get().a2a.enabled:
             return
-        agents: dict[str, Agent] = Runtime.instance().agents()
+        agents: dict[str, Agent] = GlobalRuntime.instance().agents()
         for name, agent in agents.items():
             whitelisted = AKConfig.get().a2a.agents == ["*"] or name in AKConfig.get().a2a.agents
             if not whitelisted:

ak-py/src/agentkernel/api/agent.py

@@ -7,7 +7,7 @@
 from pydantic import BaseModel
 
 from ..api.rest_request_handler import RESTRequestHandler
-from ..core import AgentService, Runtime
+from ..core import AgentService, GlobalRuntime
 
 
 class AgentRESTRequestHandler(RESTRequestHandler):
@@ -41,7 +41,7 @@ def health():
 
         @router.get("/agents")
         def list_agents():
-            return {"agents": list(Runtime.instance().agents().keys())}
+            return {"agents": list(GlobalRuntime.instance().agents().keys())}
 
         @router.post("/run")
         async def run(req: AgentRESTRequestHandler.RunRequest):

ak-py/src/agentkernel/api/rest_request_handler.py

@@ -20,7 +20,7 @@ def health():
 
         @router.get("/agents")
         def list_agents():
-            return {"agents": list(Runtime.instance().agents().keys())}
+            return {"agents": list(GlobalRuntime.instance().agents().keys())}
 
         """
         pass

ak-py/src/agentkernel/core/__init__.py

@@ -14,6 +14,6 @@
 from .base import Agent, Runner, Session
 from .config import AKConfig as Config
 from .module import Module
-from .runtime import Runtime
+from .runtime import GlobalRuntime, Runtime
 from .service import AgentService
 from .sessions.redis import RedisDriver, RedisSessionSerde

ak-py/src/agentkernel/core/runtime.py

@@ -4,6 +4,7 @@
 from types import ModuleType
 from typing import Any, Optional
 
+from deprecated import deprecated
 from singleton_type import Singleton
 
 from .base import Agent, Session
@@ -48,6 +49,7 @@ def __exit__(self, exc_type, exc_val, exc_tb) -> None:
         """
         ModuleLoader.detach(self)
 
+    @deprecated(version="0.2.4", reason="Use GlobalRuntime.instance() instead")
     @staticmethod
     def instance() -> "Runtime":
         """

ak-py/src/agentkernel/core/service.py

@@ -1,7 +1,7 @@
 import logging
 import uuid
 
-from ..core import Agent, Runtime, Session
+from ..core import Agent, GlobalRuntime, Runtime, Session
 
 
 class AgentService:
@@ -14,7 +14,7 @@ def __init__(self):
         self._log = logging.getLogger("ak.core.service.agentservice")
         self._agent = None
         self._session = None
-        self._runtime = Runtime.instance()
+        self._runtime = GlobalRuntime.instance()
 
     @property
     def runtime(self) -> Runtime:

ak-py/src/agentkernel/mcp/akmcp.py

@@ -4,7 +4,7 @@
 from fastmcp import Context, FastMCP
 from fastmcp.server.http import StarletteWithLifespan
 
-from ..core import Agent, AgentService, Runtime
+from ..core import Agent, AgentService, GlobalRuntime
 from ..core.config import AKConfig
 
 
@@ -60,7 +60,7 @@ def _build(cls):
         if cls._fastmcp is None:
             cls._fastmcp = FastMCP("Agent Kernel FastMCP Instance")
         if AKConfig.get().mcp.expose_agents:
-            agents: dict[str, Agent] = Runtime.instance().agents()
+            agents: dict[str, Agent] = GlobalRuntime.instance().agents()
             for name, agent in agents.items():
                 whitelisted = AKConfig.get().mcp.agents == ["*"] or name in AKConfig.get().mcp.agents
                 if not whitelisted: