diff options
| author | haoyuren <13851610112@163.com> | 2026-04-01 17:27:01 -0500 |
|---|---|---|
| committer | haoyuren <13851610112@163.com> | 2026-04-01 17:27:01 -0500 |
| commit | f717968f55960331c2f00852f43d4a879d0b39d8 (patch) | |
| tree | 1eb152faa46daa435158b358f2ce88806e158ce3 /broker.py | |
| parent | 6e03525ae651616a9a2c935e58674ce31472eb19 (diff) | |
Diffstat (limited to 'broker.py')
| -rw-r--r-- | broker.py | 3 |
1 files changed, 2 insertions, 1 deletions
@@ -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]} |
