{
"event": "PreToolUse",
"tool_name": "Bash",
"tool_input": {
"command": "grep -B5 -A30 \"run_full_pipeline\" \/opt\/scripts\/pipeline\/pipeline.py | head -50",
"description": "Check run_full_pipeline function"
}
}
{
"tool_response": {
"stdout": " print(f\"Queued {queued} files\")\n\n return files\n\n\ndef run_full_pipeline():\n \"\"\"Run complete pipeline: scan → process → embed.\"\"\"\n print(\"=\" * 50)\n print(\"KI-System Pipeline - Full Run\")\n print(\"=\" * 50)\n\n print(\"\\n[1\/3] Scanning for documents...\")\n files = run_scan()\n\n if files:\n print(f\"\\n[2\/3] Processing {len(files)} documents...\")\n process_queue()\n else:\n print(\"\\n[2\/3] No new documents to process\")\n\n print(\"\\n[3\/3] Embedding remaining chunks...\")\n embedded = embed_pending_chunks()\n print(f\"Embedded {embedded} chunks\")\n\n print(\"\\n\" + \"=\" * 50)\n print(\"Pipeline complete!\")\n\n\ndef main():\n \"\"\"Main entry point.\"\"\"\n if len(sys.argv) < 2:\n print(__doc__)\n return\n\n command = sys.argv[1].lower()\n\n--\n elif command == \"embed\":\n count = embed_pending_chunks()\n print(f\"Embedded {count} chunks\")\n\n elif command == \"all\":\n run_full_pipeline()\n\n elif command == \"file\" and len(sys.argv) > 2:\n file_path = sys.argv[2]\n if os.path.exists(file_path):\n success = process_file(file_path)\n print(f\"Processing {'successful' if success else 'failed'}\")\n else:",
"stderr": "",
"interrupted": false,
"isImage": false
}
}