From f717968f55960331c2f00852f43d4a879d0b39d8 Mon Sep 17 00:00:00 2001
From: haoyuren <13851610112@163.com>
Date: Wed, 1 Apr 2026 17:27:01 -0500
Subject: Fix: empty target query no longer returns all tasks

---
 broker.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

(limited to 'broker.py')

diff --git a/broker.py b/broker.py
index 35ba21c..2b5d5d6 100644
--- a/broker.py
+++ b/broker.py
@@ -1090,8 +1090,9 @@ def get_pending_tasks(target: str = ""):
             (target,),
         ).fetchall()
     else:
+        # 空 target 查询只返回 target 也为空的任务（防止跨 session 抢任务）
         rows = db.execute(
-            "SELECT id, target, type, content, created_at FROM tasks WHERE status = 'pending' ORDER BY created_at"
+            "SELECT id, target, type, content, created_at FROM tasks WHERE status = 'pending' AND target = '' ORDER BY created_at"
         ).fetchall()
     db.close()
     return {"tasks": [dict(r) for r in rows]}
-- 
cgit v1.2.3