{
"event": "PreToolUse",
"tool_name": "Bash",
"tool_input": {
"command": "grep -A15 \"get_pending_queue_items\" \/opt\/scripts\/pipeline\/db.py",
"description": "Check get_pending_queue_items function"
}
}
{
"tool_response": {
"stdout": " def get_pending_queue_items(self, limit=10):\n \"\"\"Get pending items from queue.\"\"\"\n cursor = self.execute(\n \"\"\"SELECT id, file_path, action, retry_count\n FROM pipeline_queue\n WHERE status = 'pending'\n ORDER BY created_at\n LIMIT %s\"\"\",\n (limit,),\n )\n results = cursor.fetchall()\n cursor.close()\n return results\n\n def update_queue_status(self, queue_id, status, error_message=None):\n \"\"\"Update queue item status.\"\"\"",
"stderr": "",
"interrupted": false,
"isImage": false
}
}