fix: add owner_id to _create_next_task INSERT

2026-08-08 11:16:23 +08:00 · 2026-08-08 11:16:23 +08:00 · 83ad318801
commit 83ad318801
parent e76fa0fc47
1 changed files with 1 additions and 0 deletions
--- a/pipeline_service/agent_loop.py
+++ b/pipeline_service/agent_loop.py
@ -290,6 +290,7 @@ async def _create_next_task(sor, project_id, task, next_role, pm_comment=''):
        'id': new_task_id,
        'tenant_id': project_id,
        'pipeline_id': 'role_task',
+        'owner_id': 'pm',
        'title': new_title,
        'params': json.dumps(new_params, ensure_ascii=False),
        'role': next_role,