mirror of
https://github.com/infiniflow/ragflow.git
synced 2026-10-12 02:16:39 +00:00
fix(cli): drop PENDING as a parameter for message queue commands (#20367)
This commit is contained in:
@@ -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
|
||||
|
||||
@@ -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
|
||||
|
||||
|
||||
Reference in New Issue
Block a user