{
"event": "PreToolUse",
"tool_name": "Write",
"tool_input": {
"file_path": "\/var\/www\/scripts\/pipeline\/fix_chunk_status.py",
"content": "#!\/usr\/bin\/env python3\n\"\"\"Fix chunk status based on qdrant_id presence.\"\"\"\n\nimport mysql.connector\nimport sys\nimport os\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"
}
}
{
"tool_response": {
"type": "create",
"filePath": "\/var\/www\/scripts\/pipeline\/fix_chunk_status.py",
"content": "#!\/usr\/bin\/env python3\n\"\"\"Fix chunk status based on qdrant_id presence.\"\"\"\n\nimport mysql.connector\nimport sys\nimport os\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": [],
"originalFile": null
}
}