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