From 57a22d609838a5785f6038382a70737f946c4bff Mon Sep 17 00:00:00 2001 From: Bryan Van Deusen Date: Wed, 27 May 2026 23:06:00 -0400 Subject: [PATCH] =?UTF-8?q?fix(tests):=20repair=20test=5Fmaintenance=20?= =?UTF-8?q?=E2=80=94=20skips=5Ffresh=5Frunning=20tail=20was=20orphaned=20a?= =?UTF-8?q?t=20module=20scope=20by=20the=20inserted=20ml/archive=20sweep?= =?UTF-8?q?=20tests=20(F841/F821)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tests/test_maintenance.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/tests/test_maintenance.py b/tests/test_maintenance.py index 42d1871..0488943 100644 --- a/tests/test_maintenance.py +++ b/tests/test_maintenance.py @@ -256,6 +256,12 @@ def test_recover_stalled_task_runs_skips_fresh_running(db_sync): recovered = recover_stalled_task_runs.apply().get() assert recovered == 0 + db_sync.expire_all() + status = db_sync.execute( + select(TaskRun.status).where(TaskRun.id == fresh_id) + ).scalar_one() + assert status == "running" + def test_recover_stalled_task_runs_ml_queue_uses_longer_threshold(db_sync): """ml-queue tasks (tag_and_embed video branch) legitimately run @@ -344,12 +350,6 @@ def test_recover_stalled_task_runs_archive_task_uses_longer_threshold(db_sync): assert _status(archive_fresh_id) == "running" assert _status(archive_stale_id) == "error" - db_sync.expire_all() - status = db_sync.execute( - select(TaskRun.status).where(TaskRun.id == fresh_id) - ).scalar_one() - assert status == "running" - def test_prune_task_runs_deletes_ok_older_than_24h(db_sync): from sqlalchemy import select