diff --git a/pipeline_service/agent_loop.py b/pipeline_service/agent_loop.py
index ea30a95..c9fbbde 100644
--- 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,