From bc4e8a288f5affb0017e4acb8a9aed510c11c248 Mon Sep 17 00:00:00 2001 From: Andrey Epifancev Date: Fri, 23 Oct 2026 22:23:00 +0400 Subject: [PATCH] =?UTF-8?q?test:=20=D0=BE=D1=86=D0=B5=D0=BD=D0=BA=D0=B0=20?= =?UTF-8?q?=D0=BF=D0=B0=D0=BA=D0=B5=D1=82=D0=B0=20=D0=BD=D0=B0=20=D1=80?= =?UTF-8?q?=D0=B5=D0=B0=D0=BB=D1=8C=D0=BD=D0=BE=D0=BC=20=D0=BC=D0=BE=D0=B4?= =?UTF-8?q?=D1=83=D0=BB=D0=B5=20jira=20=D0=B2=D0=BC=D0=B5=D1=81=D1=82?= =?UTF-8?q?=D0=BE=20commands.estimate=20(#87)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude Opus 5.5 --- tests/test_queue.py | 7 +++++++ tests/test_queue_core.py | 2 +- 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/tests/test_queue.py b/tests/test_queue.py index 4fdebdd..aa23cff 100644 --- a/tests/test_queue.py +++ b/tests/test_queue.py @@ -1205,3 +1205,10 @@ def test_request_fetch_after_done_file_swept(fconn, tmp_path): r = jira_fetch.request_fetch(fconn, root, "31337", "x") assert r["state"] == "fetching" assert fconn.execute("SELECT COUNT(*) AS n FROM command WHERE type = 'fetch_attachment'").fetchone()["n"] == 2 + + +def test_estimate_sums_module_pauses_replaces_commands_estimate(conn): + """Замена утверждения test_commands про commands.estimate (функция ушла в ядро): сумма пауз реального модуля jira + через pacing -> hooks.pause -> queue.estimate.""" + settings.set_(conn, "pacing", {"ensure_fields": 120, "ensure_comment": 30, "refresh": 2}) + assert queue.estimate(conn, ["ensure_fields", "ensure_comment", "refresh"]) == 152 diff --git a/tests/test_queue_core.py b/tests/test_queue_core.py index 976ab95..d2eac4e 100644 --- a/tests/test_queue_core.py +++ b/tests/test_queue_core.py @@ -24,7 +24,7 @@ def make_stub(events, refs=()): tail=lambda cmds: {"type": "r", "params": {}} if any(c["type"] == "w" for c in cmds) else None, pause=lambda conn, ctype: 7, deliver_params=lambda conn, cmd, files_dir: cmd["params"], temp_definer=None, temp_keys_used=lambda cmd: [], substitute=lambda t, p, m: p, - drop_unresolved=lambda params, unresolved: unresolved, retry_params=lambda cmd: cmd["params"], + drop_unresolved=lambda cmd, unresolved: unresolved, retry_params=lambda cmd: cmd["params"], check_confirmed=lambda conn, cmd: (False, None), on_claim=lambda *a: None, on_failed=lambda *a: None, check_result=lambda conn, cmd, status, result, files_dir: (status, None), on_result=lambda conn, cmd, status, *a: events.append(("on_result", cmd["type"], status)),