From 94c2df46121e8891119bdc0a84ac674ac6e18800 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=B5=85=E5=BF=B5?= Date: Fri, 21 Aug 2026 15:17:40 +0800 Subject: [PATCH] =?UTF-8?q?test(scheduler):=20=E6=9B=B4=E6=96=B0messages?= =?UTF-8?q?=20job=E6=96=AD=E8=A8=80(=E5=9B=9B=E7=B1=BB=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E5=91=BD=E4=BB=A4=E5=BA=8F=E5=88=97)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude --- yunke-server/tests/test_sync_scheduler.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/yunke-server/tests/test_sync_scheduler.py b/yunke-server/tests/test_sync_scheduler.py index 4d607c1..ecb489b 100644 --- a/yunke-server/tests/test_sync_scheduler.py +++ b/yunke-server/tests/test_sync_scheduler.py @@ -572,12 +572,14 @@ async def test_safe_page_run_messages_builds_scrape_command(engine, monkeypatch) await sched._safe_page_run("messages") + # 2026-08-21: messages job 是 friends→wa-friends→四类消息的命令序列, + # 每条都调 scrape_via_page.py;最后一次执行的命令参数可断言 args = captured["args"] assert args[1].endswith("scrape_via_page.py") i = args.index("--entity") - assert args[i + 1] == "messages" + assert args[i + 1] in ("messages", "wa-messages", "group-messages", "wa-group-messages") j = args.index("--max-conversations") - assert args[j + 1] == "123" + assert args[j + 1] == "99999" async def test_safe_page_run_nonzero_rc_is_logged_not_raised(engine, monkeypatch, capsys):