{
"event": "PreToolUse",
"tool_name": "Bash",
"tool_input": {
"command": "cd \/var\/www\/scripts\/pipeline\n\necho \"=== Re-upserting one vector to trigger indexer ===\"\n.\/venv\/bin\/python << 'EOF'\nimport requests\nimport json\n\n# Get first point\nscroll = requests.post('http:\/\/localhost:6333\/collections\/documents\/points\/scroll', json={\n 'limit': 1,\n 'with_vector': True,\n 'with_payload': True\n}).json()\n\npoint = scroll['result']['points'][0]\npoint_id = point['id']\nvector = point['vector']\npayload = point['payload']\n\nprint(f'Re-upserting point {point_id}')\n\n# Upsert same point\nresp = requests.put('http:\/\/localhost:6333\/collections\/documents\/points?wait=true', json={\n 'points': [{\n 'id': point_id,\n 'vector': vector,\n 'payload': payload\n }]\n})\nprint(f'Upsert response: {resp.json()[\"status\"]}')\nEOF\n\necho \"\"\necho \"Waiting 15s...\"\nsleep 15\n\ncurl -s http:\/\/localhost:6333\/collections\/documents > \/tmp\/status.json\npython3 << 'EOF'\nimport json\nwith open('\/tmp\/status.json') as f:\n d = json.load(f)['result']\nprint(f'Indexed: {d.get(\"indexed_vectors_count\")}\/{d.get(\"points_count\")}')\nprint(f'Optimizer: {d.get(\"optimizer_status\")}')\nEOF",
"timeout": 60000,
"description": "Re-upsert vector to trigger indexer"
}
}
{
"tool_response": {
"stdout": "=== Re-upserting one vector to trigger indexer ===\nRe-upserting point 00290c46-e8ce-462b-98ef-0f879b5121d3\nUpsert response: ok\n\nWaiting 15s...\nIndexed: 0\/1997\nOptimizer: ok",
"stderr": "",
"interrupted": false,
"isImage": false
}
}