yumoqing/pipeline-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: _role_poller 接受 app 参数（aiohttp on_startup 信号）

Browse Source
This commit is contained in:
yumoqing 2026-08-05 17:28:23 +08:00
parent 0bd9609532
commit 99cc19f9aa
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pipeline_service/init.py
View File

@ -432,7 +432,7 @@ def load_pipeline_service():
# Background poller: auto-dispatch submitted role_tasks to role agents # Background poller: auto-dispatch submitted role_tasks to role agents
_logger = logging.getLogger("pipeline.agent_poller") _logger = logging.getLogger("pipeline.agent_poller")
async def _role_poller(): async def _role_poller(app):
"""轮询 pipeline_tasks 中待执行的 role_task，交给对应角色agent执行。""" """轮询 pipeline_tasks 中待执行的 role_task，交给对应角色agent执行。"""
from sqlor.dbpools import DBPools from sqlor.dbpools import DBPools
poll_db = DBPools() poll_db = DBPools()