{
"event": "PreToolUse",
"tool_name": "Read",
"tool_input": {
"file_path": "\/var\/www\/migration\/content-pipeline\/src\/fix_chunk_status.py",
"limit": 30
}
}
{
"tool_response": {
"type": "text",
"file": {
"filePath": "\/var\/www\/migration\/content-pipeline\/src\/fix_chunk_status.py",
"content": "#!\/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 \"\"\")",
"numLines": 30,
"startLine": 1,
"totalLines": 57
}
}
}