mirror of
https://github.com/agent0ai/agent-zero.git
synced 2026-05-08 01:41:42 +00:00
WebSocket merge
This commit is contained in:
parent
6ca84022d8
commit
4932e12546
124 changed files with 12072 additions and 757 deletions
|
|
@ -1,7 +1,7 @@
|
|||
from python.helpers.api import ApiHandler, Request, Response
|
||||
from python.helpers import message_queue as mq
|
||||
from agent import AgentContext
|
||||
|
||||
from python.helpers.state_monitor_integration import mark_dirty_for_context
|
||||
|
||||
class MessageQueueRemove(ApiHandler):
|
||||
"""Remove message(s) from queue."""
|
||||
|
|
@ -13,4 +13,6 @@ class MessageQueueRemove(ApiHandler):
|
|||
|
||||
item_id = input.get("item_id") # None means clear all
|
||||
remaining = mq.remove(context, item_id)
|
||||
mark_dirty_for_context(context.id, reason="message_queue_remove")
|
||||
|
||||
return {"ok": True, "remaining": remaining}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue