{
"event": "PreToolUse",
"tool_name": "Edit",
"tool_input": {
"file_path": "\/var\/www\/migration\/content-pipeline\/src\/fix_chunk_status.py",
"old_string": "def main():\n print(\"Connecting to database...\")\n config = DB_CONFIG.copy()\n config[\"database\"] = \"ki_content\"\n conn = mysql.connector.connect(**config)",
"new_string": "def main():\n print(\"Connecting to database...\")\n # Uses DB_CONFIG from config.py (configured via environment)\n conn = mysql.connector.connect(**DB_CONFIG)"
}
}
{
"tool_response": {
"filePath": "\/var\/www\/migration\/content-pipeline\/src\/fix_chunk_status.py",
"oldString": "def main():\n print(\"Connecting to database...\")\n config = DB_CONFIG.copy()\n config[\"database\"] = \"ki_content\"\n conn = mysql.connector.connect(**config)",
"newString": "def main():\n print(\"Connecting to database...\")\n # Uses DB_CONFIG from config.py (configured via environment)\n conn = mysql.connector.connect(**DB_CONFIG)",
"originalFile": "#!\/usr\/bin\/env python3\n\"\"\"Fix chunk status based on qdrant_id presence.\"\"\"\n\nimport os\nimport sys\n\nimport mysql.connector\n\nsys.path.insert(0, os.path.dirname(os.path.abspath(__file__)))\nfrom config import DB_CONFIG\n\n\ndef main():\n print(\"Connecting to database...\")\n config = DB_CONFIG.copy()\n config[\"database\"] = \"ki_content\"\n conn = mysql.connector.connect(**config)\n cursor = conn.cursor(dictionary=True)\n\n # Count chunks by status\n cursor.execute(\"SELECT status, COUNT(*) as cnt FROM chunks GROUP BY status\")\n before = {row[\"status\"]: row[\"cnt\"] for row in cursor.fetchall()}\n print(f\"Before: {before}\")\n\n # Update chunks with qdrant_id to 'embedded'\n cursor.execute(\"\"\"\n UPDATE chunks\n SET status = 'embedded'\n WHERE qdrant_id IS NOT NULL AND (status IS NULL OR status = 'created')\n \"\"\")\n embedded_count = cursor.rowcount\n print(f\"Set {embedded_count} chunks to 'embedded' (have qdrant_id)\")\n\n # Update chunks without qdrant_id to 'created'\n cursor.execute(\"\"\"\n UPDATE chunks\n SET status = 'created'\n WHERE qdrant_id IS NULL AND (status IS NULL OR status = '')\n \"\"\")\n created_count = cursor.rowcount\n print(f\"Set {created_count} chunks to 'created' (no qdrant_id)\")\n\n conn.commit()\n\n # Count after\n cursor.execute(\"SELECT status, COUNT(*) as cnt FROM chunks GROUP BY status\")\n after = {row[\"status\"]: row[\"cnt\"] for row in cursor.fetchall()}\n print(f\"After: {after}\")\n\n cursor.close()\n conn.close()\n print(\"Done!\")\n\n\nif __name__ == \"__main__\":\n main()\n",
"structuredPatch": [
{
"oldStart": 12,
"oldLines": 9,
"newStart": 12,
"newLines": 8,
"lines": [
" ",
" def main():",
" print(\"Connecting to database...\")",
"- config = DB_CONFIG.copy()",
"- config[\"database\"] = \"ki_content\"",
"- conn = mysql.connector.connect(**config)",
"+ # Uses DB_CONFIG from config.py (configured via environment)",
"+ conn = mysql.connector.connect(**DB_CONFIG)",
" cursor = conn.cursor(dictionary=True)",
" ",
" # Count chunks by status"
]
}
],
"userModified": false,
"replaceAll": false
}
}