From fc578eabf8e58d76a5f034e6ed3e14c84a4f4d8a Mon Sep 17 00:00:00 2001 From: ciel <149575453+flyingwhit@users.noreply.github.com> Date: Wed, 30 Sep 2026 09:42:59 +0800 Subject: [PATCH] fix(cli): drop PENDING as a parameter for message queue commands (#20367) --- docs/administrator/admin/ragflow_cli.md | 6 +----- internal/cli/admin_parser.go | 4 +--- 2 files changed, 2 insertions(+), 8 deletions(-) diff --git a/docs/administrator/admin/ragflow_cli.md b/docs/administrator/admin/ragflow_cli.md index 9c1d3bddb7..8ad6f9126d 100644 --- a/docs/administrator/admin/ragflow_cli.md +++ b/docs/administrator/admin/ragflow_cli.md @@ -574,13 +574,9 @@ Lists messages currently retained in the task stream. The optional `PENDING` key **Syntax** ```sql -MQ LIST [PENDING]; +MQ LIST; ``` -| Parameter | Required | Description | -| --- | --- | --- | -| `[PENDING]` | No | Requests the pending-message form of the command. | - **Example** ```text diff --git a/internal/cli/admin_parser.go b/internal/cli/admin_parser.go index 3ea4f462b3..a32cf64cb1 100644 --- a/internal/cli/admin_parser.go +++ b/internal/cli/admin_parser.go @@ -2690,11 +2690,9 @@ func (p *Parser) parseMessageQueueCommand() (*Command, error) { cmd = NewCommand("user_list_message_queue_command") if p.curToken.Type == TokenPending { - cmd.Params["pending"] = true p.nextToken() // consume PENDING - } else { - cmd.Params["pending"] = false } + case TokenPublish: p.nextToken() // consume PUBLISH