Skip to content

Commit 9787ec0

Browse files
committed
Increase WebSocket client message queue size to 20
Bump the multiprocessing message_queue maxsize from 10 to 20 in src/om1_utils/ws/client.py to reduce backpressure and accommodate higher incoming message throughput.
1 parent 1e92fbe commit 9787ec0

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/om1_utils/ws/client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,7 @@ def __init__(self, url: str = "ws://localhost:6789"):
158158
self.websocket: Optional[ClientConnection] = None
159159
self.message_callback: Optional[Callable] = None
160160

161-
self.message_queue: mp.Queue = mp.Queue(maxsize=10)
161+
self.message_queue: mp.Queue = mp.Queue(maxsize=20)
162162
self._incoming_queue: mp.Queue = mp.Queue()
163163
self._state_queue: mp.Queue = mp.Queue()
164164
self._control_queue: mp.Queue = mp.Queue()

0 commit comments

Comments
 (0)