kin: auto-commit after pipeline

agents/runner.py

@@ -848,6 +848,12 @@ def _save_decomposer_output(
         ).fetchone()
         if existing:
             skipped += 1
+            _logger.info(
+                "task_decomposer: skip duplicate child task '%s' (parent=%s, existing=%s)",
+                title,
+                parent_task_id,
+                existing[0],
+            )
             continue
         category = (item.get("category") or "").strip().upper()
         if category not in models.TASK_CATEGORIES: