From 99ebd8810095dd33fbeacdf032a104451c2c3480 Mon Sep 17 00:00:00 2001
From: ymq <ymq@opencomputing.net>
Date: Tue, 11 Aug 2026 15:04:46 +0800
Subject: [PATCH] fix: clear claimed_by on PM reject

---
 pipeline_service/agent_loop.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pipeline_service/agent_loop.py b/pipeline_service/agent_loop.py
index 6928513..10b0ac9 100644
--- a/pipeline_service/agent_loop.py
+++ b/pipeline_service/agent_loop.py
@@ -784,7 +784,7 @@ async def pm_review_run(project_id, agent_id=None, model_name=None):
             from .questions import agent_ask
             rejection_q = decision.get("questions") or comment or "交付件不满足要求"
             await agent_ask(project_id, task_id, "pm", rejection_q, context={"pm_comment": comment, "deliverable_type": deliverable_type})
-            await sor.sqlExe("UPDATE pipeline_tasks SET state='submitted' WHERE id=${tid}$", {"tid": task_id})
+            await sor.sqlExe("UPDATE pipeline_tasks SET state='submitted', claimed_by=NULL WHERE id=${tid}$", {"tid": task_id})
             return {"status": "rejected", "task_id": task_id, "comment": comment, "question": rejection_q}
 
         else: