From e7e0342aeb0402a1c3eb998f900b940c7d147244 Mon Sep 17 00:00:00 2001 From: Gros Frumos Date: Tue, 17 Mar 2026 20:58:06 +0200 Subject: [PATCH] kin: auto-commit after pipeline --- tests/test_kin_101_regression.py | 4 ++-- tests/test_watchdog.py | 10 +++++----- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/tests/test_kin_101_regression.py b/tests/test_kin_101_regression.py index 2d41acd..8ee063f 100644 --- a/tests/test_kin_101_regression.py +++ b/tests/test_kin_101_regression.py @@ -204,9 +204,9 @@ class TestPipelineNoFramework: assert result["success"] is True # _run_project_tests NOT called mock_tests.assert_not_called() - # Task NOT blocked + # Task should be in review (auto_eligible=False → runner sets status='review') task = models.get_task(conn, "VDOL-001") - assert task["status"] != "blocked" + assert task["status"] == "review" @patch("agents.runner._run_autocommit") @patch("agents.runner._detect_test_command") diff --git a/tests/test_watchdog.py b/tests/test_watchdog.py index 494e5dc..d42e64b 100644 --- a/tests/test_watchdog.py +++ b/tests/test_watchdog.py @@ -95,7 +95,7 @@ def test_watchdog_alive_pid_no_change(tmp_path): pipeline_row = conn.execute("SELECT status FROM pipelines WHERE id=?", (pipeline_id,)).fetchone() conn.close() - assert task["status"] != "blocked" + assert task["status"] == "pending" assert pipeline_row["status"] == "running" @@ -137,7 +137,7 @@ def test_watchdog_pipeline_without_pid_skipped(tmp_path): task = models.get_task(conn, tid) conn.close() - assert task["status"] != "blocked" + assert task["status"] == "pending" # --------------------------------------------------------------------------- @@ -356,7 +356,7 @@ def test_check_dead_pipelines_permission_error_ignored(tmp_path): ).fetchone() conn.close() - assert task["status"] != "blocked" + assert task["status"] == "pending" assert pipeline_row["status"] == "running" @@ -379,7 +379,7 @@ def test_check_parent_alive_eacces_does_not_abort(conn): assert result is False task = models.get_task(conn, "VDOL-001") - assert task["status"] != "blocked" + assert task["status"] == "pending" def test_check_parent_alive_process_lookup_error_aborts(conn): @@ -456,5 +456,5 @@ def test_check_dead_pipelines_kill_succeeds_no_change(tmp_path): ).fetchone() conn.close() - assert task["status"] != "blocked" + assert task["status"] == "pending" assert pipeline_row["status"] == "running"