chenxin
c63b75152a
- 天工阁域 domains/tiangong：backstage_tasks（委托包+验收标准+结果证据）；有限分解（parent 链）与受控并行（各自后台 Run）；子任务全终态级联父任务进入待验收；按证据 accept/reject - kernel.start_backstage_run（kind=background_task）：loop 后台分支不占前台席位、与前台对话并行；断言放宽容纳无人物功能任务；结果只经回调回呈任务——无身份写入路径 - 叩心域 domains/kouxin：knocking_candidates（event/time_anchor/manual 触发 + 草稿 + 裁决快照）；四约束裁决（总开关→静默窗口【本地时区判定】→24h 频率→预算），dispatch 未过 429 且快照留痕；候选默认不自动发送；expire_stale 过期推进不触碰缘契 - 辰正 domains/zhengchen：temporal_context() 复用 time_sense 计算核（快照/农历/季节），产出【时态感知】投影段接入镜树生成 prompt（客观时间语境，不附情绪臆测——守一纪律） - 退役：modules/goal_orchestrator|planner|perception|big_cycle、application/planning、services/governance|goal_persist、candidates 表链（imports 候选抽取 API 面）、goals/plans/agent_roster/perception_channels/big_cycles/旧候选表（迁移 009）；前端 admin goals/plans/agents/perception/world 页与六组件；governance 只留 GenerationPreferences；admin 治理面收敛为司命+百工两枢；pivots 健康以域表计数重建 - 验收（test_m8_tiangong 五用例）：后台任务无身份写入（记忆/魂籍/缘契零新增）；后台与前台并行；分解级联；叩心四约束逐项；不回应不降低关系（缘契维度/状态/版本零变化） - 四套件：后端 345、前端 203、BFF 4、神识 5 包全绿（2 个预存环境失败不变）；迁移 009 净库干净
207 lines
6.8 KiB
Python
207 lines
6.8 KiB
Python
"""极小硬核 Kernel：不变量裁决、命台并发控制、事件日志写入、Run 循环骨架。
|
||
|
||
不可插拔（lingtai-runtime.md §1）；插件与 Profile 见 ``app.runtime``。
|
||
"""
|
||
|
||
from __future__ import annotations
|
||
|
||
import asyncio
|
||
|
||
from sqlalchemy.ext.asyncio import AsyncSession, async_sessionmaker
|
||
|
||
from app.kernel.eventlog import KernelEventLog
|
||
from app.kernel.loop import KernelRunLoop, OnRunFinal
|
||
from app.kernel.seat import SeatManager
|
||
from app.models.runtime import Run
|
||
from app.runtime.bus import WaterfallBus
|
||
from app.runtime.profile import resolve_profile
|
||
from app.shenshi_client.client import ShenshiClient
|
||
|
||
__all__ = ["Kernel", "KernelEventLog", "KernelRunLoop", "SeatManager"]
|
||
|
||
|
||
class Kernel:
|
||
"""门面：持有 Kernel 全部部件，供 lifespan 装配与 API 层调用。"""
|
||
|
||
def __init__(
|
||
self,
|
||
*,
|
||
shenshi: ShenshiClient,
|
||
session_factory: async_sessionmaker[AsyncSession],
|
||
event_log: KernelEventLog,
|
||
bus: WaterfallBus | None = None,
|
||
seats: SeatManager | None = None,
|
||
timeout_seconds: float = 120.0,
|
||
) -> None:
|
||
self._sessions = session_factory
|
||
self.bus = bus or WaterfallBus()
|
||
self.seats = seats or SeatManager()
|
||
self.loop = KernelRunLoop(
|
||
event_log=event_log,
|
||
seats=self.seats,
|
||
bus=self.bus,
|
||
shenshi=shenshi,
|
||
session_factory=session_factory,
|
||
timeout_seconds=timeout_seconds,
|
||
)
|
||
self._tasks: set[asyncio.Task[None]] = set()
|
||
|
||
async def start_foreground_run(
|
||
self,
|
||
*,
|
||
character_id: str,
|
||
prompt: str,
|
||
owner_id: str = "",
|
||
trace_id: str | None = None,
|
||
system_contract: str | None = None,
|
||
origin: str = "kernel",
|
||
on_run_final: OnRunFinal | None = None,
|
||
temperature: float | None = None,
|
||
max_tokens: int | None = None,
|
||
) -> Run:
|
||
"""创建 Run 行（queued）并异步启动循环；前台席位在循环内排队获取。"""
|
||
profile = resolve_profile()
|
||
async with self._sessions() as session:
|
||
run = Run(
|
||
character_id=character_id,
|
||
owner_id=owner_id,
|
||
status="queued",
|
||
kind="foreground",
|
||
goal=prompt[:300] if prompt else None,
|
||
origin=origin,
|
||
model_hint=str(profile.params.get("slot", "chat")),
|
||
)
|
||
session.add(run)
|
||
await session.commit()
|
||
run_id = run.id
|
||
self._spawn(
|
||
run_id=run_id,
|
||
character_id=character_id,
|
||
owner_id=owner_id,
|
||
prompt=prompt,
|
||
trace_id=trace_id,
|
||
seat_key=None,
|
||
system_contract=system_contract,
|
||
on_final=on_run_final,
|
||
temperature=temperature,
|
||
max_tokens=max_tokens,
|
||
)
|
||
async with self._sessions() as session:
|
||
created = await session.get(Run, run_id)
|
||
assert created is not None
|
||
return created
|
||
|
||
async def start_backstage_run(
|
||
self,
|
||
*,
|
||
character_id: str | None,
|
||
prompt: str,
|
||
owner_id: str = "",
|
||
on_task_final=None,
|
||
) -> Run:
|
||
"""天工阁受托任务 Run（kind=background_task）：不占前台席位、并行于前台。
|
||
|
||
无身份写入路径：结果只回呈任务（on_task_final），不触发记忆候选与身份写入
|
||
（息壤归真提取只挂在 canonize 链上，后台 Run 不归真）。
|
||
"""
|
||
profile = resolve_profile()
|
||
async with self._sessions() as session:
|
||
run = Run(
|
||
character_id=character_id,
|
||
owner_id=owner_id,
|
||
status="queued",
|
||
kind="background_task",
|
||
goal=prompt[:300] if prompt else None,
|
||
origin="tiangong_task",
|
||
model_hint=str(profile.params.get("slot", "chat")),
|
||
)
|
||
session.add(run)
|
||
await session.commit()
|
||
run_id = run.id
|
||
self._spawn(
|
||
run_id=run_id,
|
||
character_id=character_id,
|
||
owner_id=owner_id,
|
||
prompt=prompt,
|
||
trace_id=None,
|
||
seat_key=None,
|
||
system_contract=None,
|
||
on_final=on_task_final,
|
||
background=True,
|
||
)
|
||
async with self._sessions() as session:
|
||
created = await session.get(Run, run_id)
|
||
assert created is not None
|
||
return created
|
||
|
||
async def start_rehearsal_run(
|
||
self, *, embryo_id: str, prompt: str, system_contract: str, owner_id: str = ""
|
||
) -> Run:
|
||
"""照心试演（幻境 Run）：无正式人物、不占人物命台、不产生人物经历。"""
|
||
profile = resolve_profile()
|
||
async with self._sessions() as session:
|
||
run = Run(
|
||
character_id=None,
|
||
owner_id=owner_id,
|
||
status="queued",
|
||
kind="rehearsal",
|
||
goal=prompt[:300] if prompt else None,
|
||
origin="embryo_rehearse",
|
||
model_hint=str(profile.params.get("slot", "chat")),
|
||
)
|
||
session.add(run)
|
||
await session.commit()
|
||
run_id = run.id
|
||
self._spawn(
|
||
run_id=run_id,
|
||
character_id=None,
|
||
owner_id=owner_id,
|
||
prompt=prompt,
|
||
trace_id=None,
|
||
seat_key=f"embryo:{embryo_id}",
|
||
system_contract=system_contract,
|
||
on_final=None,
|
||
)
|
||
async with self._sessions() as session:
|
||
created = await session.get(Run, run_id)
|
||
assert created is not None
|
||
return created
|
||
|
||
@property
|
||
def shenshi(self) -> ShenshiClient:
|
||
"""神识客户端（息壤提取等功能任务的受控取用点）。"""
|
||
return self.loop._shenshi # noqa: SLF001
|
||
|
||
def _spawn(
|
||
self,
|
||
*,
|
||
run_id: str,
|
||
character_id: str | None,
|
||
owner_id: str,
|
||
prompt: str,
|
||
trace_id: str | None,
|
||
seat_key: str | None,
|
||
system_contract: str | None,
|
||
on_final: OnRunFinal | None,
|
||
temperature: float | None = None,
|
||
max_tokens: int | None = None,
|
||
background: bool = False,
|
||
) -> None:
|
||
task = asyncio.create_task(
|
||
self.loop.execute(
|
||
run_id=run_id,
|
||
character_id=character_id,
|
||
owner_id=owner_id,
|
||
prompt=prompt,
|
||
trace_id=trace_id,
|
||
seat_key=seat_key,
|
||
system_contract=system_contract,
|
||
on_final=on_final,
|
||
temperature=temperature,
|
||
max_tokens=max_tokens,
|
||
background=background,
|
||
)
|
||
)
|
||
self._tasks.add(task)
|
||
task.add_done_callback(self._tasks.discard)
|