MCPcopy Index your code
hub / github.com/OpenBMB/ChatDev / enqueue

Function enqueue

server/routes/execute_sync.py:206–207  ·  view source on GitHub ↗
(event_type: str, data: Any)

Source from the content-addressed store, hash-verified

204 done_event = threading.Event()
205
206 def enqueue(event_type: str, data: Any) -> None:
207 event_queue.put((event_type, data))
208
209 def worker() -> None:
210 try:

Callers 1

workerFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected