chore(deps): move to apodex-agent-core 0.12.0 and drop 0.11.1 workarounds

- Pin apodex-agent-core==0.12.0.
- infra/openai_client.py is a plain alias again (AgentCore treats an empty
  api_key as unset); only the session-affinity resolvers are configured.
- TaskBoardObserver aliases the shared class (now critical upstream).
- loop_types no longer hand re-exports wall_deadline_remaining_s (in
  __all__ upstream).
- create_file annotates its rows/data shorthand shapes explicitly instead of
  patching items to {}, so every schema node keeps a concrete type for
  strict validators.
- create_subagent uses the public bind_max_tokens instead of _ensure_bound.

Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>

Author: zhanghanduo

CHANGELOG.md

@@ -12,7 +12,7 @@ Initial open-source release of FrontierAgent.
 ### Changed
 
 - **Runtime engine moved to [`apodex-agent-core`](https://pypi.org/project/apodex-agent-core/)
-  (pinned `==0.11.1`).** The agent loop, loop contracts, tool execution,
+  (pinned `==0.12.0`).** The agent loop, loop contracts, tool execution,
   compaction, observers, AgentBus, DAG and providers now come from `agent_core`;
   `frontier_agent.*` keeps its import paths as `sys.modules` aliases or thin
   adapters, so workflows, apodex and benchmarks are unchanged. Product policy is
@@ -22,7 +22,7 @@ Initial open-source release of FrontierAgent.
   follows AgentCore where the fork had diverged, notably: compaction pins the
   first user message verbatim and replaces legacy prose spill indexes, and
   `Any`-typed tool parameters generate `{"type": "string"}` (`create_file`
-  restores open `items` for its shorthand arrays).
+  now annotates its `rows` / `data` shorthand shapes explicitly).
 
 ### Added
 

frontier_agent/components/observers/task_board.py

@@ -1,16 +1,9 @@
-"""Task-board reminders (shared ``TaskBoardObserver`` with product policy)."""
+# pyright: reportWildcardImportFromLibrary=false
+"""Task-board reminders (implemented by ``agent_core.components.observers.task_board``)."""
 
-from agent_core.components.observers.task_board import TaskBoardObserver as _TaskBoardObserver
+import sys
 
+import agent_core.components.observers.task_board as _implementation
+from agent_core.components.observers.task_board import *  # noqa: F403
 
-class TaskBoardObserver(_TaskBoardObserver):
-    """Critical, so the board reminder is collected into the next turn.
-
-    AgentCore defaults this observer to non-critical, where return values are
-    dropped and the reminder would never reach the model.
-    """
-
-    critical: bool = True
-
-
-__all__ = ["TaskBoardObserver"]
+sys.modules[__name__] = _implementation

frontier_agent/core/loop_types.py

@@ -5,8 +5,5 @@
 
 import agent_core.loop_types as _implementation
 from agent_core.loop_types import *  # noqa: F403
-from agent_core.loop_types import (  # not in __all__; named for static checkers
-    wall_deadline_remaining_s as wall_deadline_remaining_s,
-)
 
 sys.modules[__name__] = _implementation

frontier_agent/core/runtime/loop/_bind.py

@@ -7,9 +7,6 @@
 from agent_core.runtime.loop._bind import (
     _BoundLLM as _BoundLLM,
 )
-from agent_core.runtime.loop._bind import (
-    _ensure_bound as _ensure_bound,
-)
 from agent_core.runtime.loop._bind import (
     bind_max_tokens,
     bind_temperature,
@@ -34,7 +31,6 @@ def bind_session_id(llm: Any, task_id: str) -> Any:
 
 __all__ = [
     "_BoundLLM",
-    "_ensure_bound",
     "bind_max_tokens",
     "bind_session_id",
     "bind_temperature",

frontier_agent/core/runtime/loop/llm_client.py

@@ -21,7 +21,6 @@
 from agent_core.tokens import estimate_message_tokens, estimate_text_tokens
 
 from frontier_agent.core.runtime.loop._bind import (
-    _ensure_bound,
     bind_max_tokens,
     bind_session_id,
     bind_temperature,
@@ -37,7 +36,6 @@
     "LLMReasoningRunaway",
     "LLMStreamStalled",
     "ThinkTagSplitter",
-    "_ensure_bound",
     "bind_max_tokens",
     "bind_session_id",
     "bind_temperature",

frontier_agent/infra/openai_client.py

@@ -1,3 +1,4 @@
+# pyright: reportWildcardImportFromLibrary=false
 """FrontierAgent composition of AgentCore's OpenAI Chat Completions client.
 
 Importing this module wires FrontierAgent's session-affinity policy into the
@@ -6,27 +7,14 @@
 directly before this import silently drops the session id.
 """
 
-from __future__ import annotations
-
-from typing import Any
+import sys
 
 import agent_core.providers.openai_chat as _implementation
+from agent_core.providers.openai_chat import *  # noqa: F403
 
 from frontier_agent.infra.session_context import get_task_session_id, mirror_session_query
 
 _implementation.configure_session_query_resolver(mirror_session_query)
 _implementation.configure_session_scope_resolver(get_task_session_id)
 
-
-class OpenAIClient(_implementation.OpenAIClient):
-    """Treat an empty ``api_key`` as unspecified.
-
-    The OpenAI SDK only consults ``OPENAI_API_KEY`` when ``api_key`` is None;
-    a cached config can legitimately hold the pre-environment empty string.
-    """
-
-    def __init__(self, model: str, *, api_key: str | None = None, **kwargs: Any) -> None:
-        super().__init__(model, api_key=api_key or None, **kwargs)
-
-
-__all__ = ["OpenAIClient"]
+sys.modules[__name__] = _implementation

plugins/tools/create_file.py

@@ -27,6 +27,13 @@
 
 logger = logging.getLogger(__name__)
 
+# Shorthand payload shapes, spelled out so every schema node carries a concrete
+# ``type``: strict function-schema validators reject an untyped property, and
+# ``Any`` would degrade to ``string`` and reject nested rows instead.
+_Scalar = str | int | float | bool
+_Rows = list[list[_Scalar] | dict[str, Any]]
+_JsonArray = list[dict[str, Any] | list[_Scalar] | _Scalar]
+
 _WRITER_SRC = writer_src()
 _DOC_EXTS = {"docx", "xlsx", "pptx"}
 _TEXT_EXTS = {"txt", "md", "csv", "tsv", "json", "jsonl", "html", "htm"}
@@ -210,8 +217,8 @@ def desugar_text_shorthand(
     *,
     ops: list[dict[str, Any]] | str | None,
     content: str | None,
-    rows: list[Any] | str | None,
-    data: dict[str, Any] | list[Any] | str | None,
+    rows: _Rows | str | None,
+    data: dict[str, Any] | _JsonArray | str | None,
     overwrite: bool = False,
 ) -> tuple[list[dict[str, Any]] | str | None, str]:
     """Fold a top-level ``content``/``rows``/``data`` into one ``create`` op.
@@ -258,8 +265,8 @@ async def create_file(
     path: str,
     ops: list[dict[str, Any]] | str | None = None,
     content: str | None = None,
-    rows: list[Any] | str | None = None,
-    data: dict[str, Any] | list[Any] | str | None = None,
+    rows: _Rows | str | None = None,
+    data: dict[str, Any] | _JsonArray | str | None = None,
     overwrite: bool = False,
 ) -> str:
     """Create or edit a deliverable file in the sandbox — office (docx/xlsx/pptx)
@@ -547,11 +554,3 @@ async def create_file(
         )
     return result.stdout or "(no output)"
 
-
-# The schema generator maps ``Any`` to ``{"type": "string"}``, which would make
-# schema-aware providers reject nested csv rows and JSON arrays. Items of these
-# shorthand arrays are genuinely open.
-for _name in ("rows", "data"):
-    for _option in create_file.parameters["properties"][_name].get("anyOf", []):
-        if _option.get("type") == "array":
-            _option["items"] = {}

plugins/tools/create_subagent.py

@@ -434,10 +434,8 @@ def _bind_sub_agent_llm(runtime: Any | None) -> Any | None:
             eff_max_tokens,
         )
     try:
-        from dataclasses import replace
-
-        from frontier_agent.core.runtime.loop.llm_client import _ensure_bound
-        bound = replace(_ensure_bound(llm), max_tokens=eff_max_tokens)
+        from frontier_agent.core.runtime.loop.llm_client import bind_max_tokens
+        bound = bind_max_tokens(llm, eff_max_tokens)
     except Exception:
         bound = llm
     stream_cfg = getattr(runtime, "stream_repetition_config", None)

pyproject.toml

@@ -8,7 +8,7 @@ requires-python = ">=3.12"
 dependencies = [
     # Runtime engine (agent loop, tools, observers, sub-agents, DAG). Pinned exactly:
     # 0.x MINOR bumps may be breaking.
-    "apodex-agent-core==0.11.1",
+    "apodex-agent-core==0.12.0",
     "pydantic>=2.0",
     "pydantic-settings>=2.14.2",
     "openai>=1.50",

tests/test_create_file_shorthand.py

@@ -67,8 +67,23 @@ def test_the_tool_schema_accepts_the_advertised_json_shapes() -> None:
         if option.get("type") == "array"
     )
 
-    assert rows_array["items"] == {}
-    assert data_array["items"] == {}
+    # Nested csv rows and jsonl objects must both validate.
+    row_shapes = {option["type"] for option in rows_array["items"]["anyOf"]}
+    assert row_shapes == {"array", "object"}
+    data_shapes = {option["type"] for option in data_array["items"]["anyOf"]}
+    assert {"array", "object", "string"} <= data_shapes
+
+    # Strict function-schema validators reject a node without a ``type``.
+    def untyped(node: object) -> list[object]:
+        if isinstance(node, dict):
+            own = [node] if "type" not in node and "anyOf" not in node else []
+            return own + [bad for child in node.values() for bad in untyped(child)]
+        if isinstance(node, list):
+            return [bad for child in node for bad in untyped(child)]
+        return []
+
+    assert untyped(properties["rows"]["anyOf"]) == []
+    assert untyped(properties["data"]["anyOf"]) == []
 
 
 def test_empty_string_content_still_folds() -> None: