kin: auto-commit after pipeline

tests/test_db.py

@@ -394,6 +394,27 @@ def test_migrate_preserves_non_dept_sub_and_non_running_pipelines():
     conn.close()
 
 
+# ---------------------------------------------------------------------------
+# Schema KIN-OBS-014: pid INTEGER присутствует в SCHEMA-строке CREATE TABLE pipelines
+# ---------------------------------------------------------------------------
+
+def test_schema_string_contains_pid_integer_in_pipelines_ddl():
+    """Регрессия KIN-OBS-014: SCHEMA-строка содержит 'pid INTEGER' в теле CREATE TABLE pipelines.
+
+    До фикса поле было только в _migrate(), но отсутствовало в SCHEMA —
+    при свежей инициализации БД колонка не создавалась.
+    Тест парсит блок CREATE TABLE pipelines напрямую из SCHEMA.
+    """
+    from core.db import SCHEMA
+    start = SCHEMA.index("CREATE TABLE IF NOT EXISTS pipelines")
+    end = SCHEMA.index(");", start) + 2
+    pipelines_ddl = SCHEMA[start:end]
+    assert "pid INTEGER" in pipelines_ddl, (
+        "pid INTEGER не найден в SCHEMA CREATE TABLE pipelines — "
+        "поле должно быть в SCHEMA (core/db.py строки ~133-148), а не только в _migrate()"
+    )
+
+
 # ---------------------------------------------------------------------------
 # Schema KIN-OBS-018: pid INTEGER присутствует в таблице pipelines
 # ---------------------------------------------------------------------------
@@ -408,7 +429,7 @@ class TestPipelinesSchemaKinObs018:
     def test_pid_defaults_to_null(self, conn):
         """Вставка pipeline без pid — значение NULL."""
         conn.execute(
-            "INSERT INTO projects (id, name) VALUES ('p_pid', 'P')"
+            "INSERT INTO projects (id, name, path) VALUES ('p_pid', 'P', '/p')"
         )
         conn.execute(
             "INSERT INTO tasks (id, project_id, title) VALUES ('t_pid', 'p_pid', 'T')"
@@ -426,7 +447,7 @@ class TestPipelinesSchemaKinObs018:
     def test_pid_can_store_integer_value(self, conn):
         """Вставка pipeline с pid — значение сохраняется в БД."""
         conn.execute(
-            "INSERT INTO projects (id, name) VALUES ('p_pid2', 'P')"
+            "INSERT INTO projects (id, name, path) VALUES ('p_pid2', 'P', '/p')"
         )
         conn.execute(
             "INSERT INTO tasks (id, project_id, title) VALUES ('t_pid2', 'p_pid2', 'T')"