修复重构后的导入错误和缺失模块
Some checks failed
构建并部署 AI Agent 服务 / deploy (push) Failing after 6m26s

This commit is contained in:
2026-04-29 17:23:20 +08:00
parent 862fef94dc
commit d6805d1db8
36 changed files with 117 additions and 60 deletions

View File

@@ -0,0 +1,21 @@
"""
Main Graph Configuration - Streaming Writer
"""
from typing import Optional, Callable, Any
_stream_writer: Optional[Callable[[Any], None]] = None
def set_stream_writer(writer: Callable[[Any], None]):
"""Set the global stream writer"""
global _stream_writer
_stream_writer = writer
def get_stream_writer() -> Callable[[Any], None]:
"""Get the global stream writer"""
global _stream_writer
if _stream_writer is None:
# Default no-op writer
def noop(_):
pass
return noop
return _stream_writer