taolib.symphony.server.routes#

Symphony API 路由定义。

提供系统状态查询、单问题详情和即时轮询触发的 REST API。

Attributes#

Functions#

get_state(→ dict[str, Any])

获取系统状态快照。

get_issue(→ dict[str, Any])

获取单个问题的详情。

trigger_refresh(→ dict[str, Any])

触发即时轮询。

_get_orchestrator_state(→ Any)

从编排器实例获取运行时状态。

_get_issue_id(→ str | None)

从 running/retry 条目中提取 issue_id。

_determine_issue_status(→ str)

判断问题当前状态。

_format_datetime(→ str | None)

将日期时间格式化为 ISO 8601。

Module Contents#

taolib.symphony.server.routes.api_router#
async taolib.symphony.server.routes.get_state(request: fastapi.Request) dict[str, Any]#

获取系统状态快照。

返回运行中的 worker 列表、重试队列、令牌汇总和配置参数。 如果编排器不可用,返回 snapshot_unavailable 错误。

async taolib.symphony.server.routes.get_issue(issue_identifier: str, request: fastapi.Request) dict[str, Any]#

获取单个问题的详情。

在运行中 worker 和重试队列中查找匹配 issue_identifier 的条目, 返回其完整详情。如果未找到,返回 404。

参数:

issue_identifier -- 人类可读的问题标识(如 "PROJ-123")。

async taolib.symphony.server.routes.trigger_refresh(request: fastapi.Request) dict[str, Any]#

触发即时轮询。

请求编排器立即执行一次轮询周期,而不是等待下一个定时触发。 返回 202 Accepted 表示请求已被接受。

如果编排器不可用,返回 503。

taolib.symphony.server.routes._get_orchestrator_state(orchestrator: Any) Any#

从编排器实例获取运行时状态。

支持多种编排器实现: - 有 get_state() 方法的编排器 - 有 state 属性的编排器 - 直接作为状态使用的编排器

taolib.symphony.server.routes._get_issue_id(running_entry: Any, retry_entry: Any) str | None#

从 running/retry 条目中提取 issue_id。

taolib.symphony.server.routes._determine_issue_status(running_entry: Any, retry_entry: Any) str#

判断问题当前状态。

taolib.symphony.server.routes._format_datetime(value: Any) str | None#

将日期时间格式化为 ISO 8601。