fd13607366
使用 psycopg_pool 作为 LangGraph checkpointer 连接池，并在启动时执行 setup() 确保表存在；Windows 下切换为 SelectorEventLoopPolicy 以兼容 psycopg 异步模式。
14 lines
463 B
Python
14 lines
463 B
Python
"""ARQ worker entrypoint."""
|
|
import asyncio
|
|
import os
|
|
import sys
|
|
|
|
# 必须放在最顶层！
|
|
if sys.platform == "win32":
|
|
# 把当前文件 (main.py) 的上一级的上一级 (即根目录 Yuxi-Know) 加入到 sys.path
|
|
sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
|
|
asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
|
|
|
|
from src.services.run_worker import WorkerSettings
|
|
|
|
__all__ = ["WorkerSettings"] |