fix ws dropping replays due to 1MB max_size limit
Raise websockets max_size to 32MB so zstd-compressed frames from Spectra that exceed the 1MB default aren't rejected before decompression. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
+1
-1
@@ -82,7 +82,7 @@ async def ws_replay_listener(callback: Callable[[List[Dict[str, Any]]], Awaitabl
|
|||||||
|
|
||||||
async def _connect_and_listen(url: str, label: str):
|
async def _connect_and_listen(url: str, label: str):
|
||||||
logger.info(f"WS attempting connect → {url}")
|
logger.info(f"WS attempting connect → {url}")
|
||||||
async with wsconnect(url, additional_headers=headers) as ws:
|
async with wsconnect(url, additional_headers=headers, max_size=32 * 1024 * 1024) as ws:
|
||||||
logger.info(f"WebSocket connected to {label}")
|
logger.info(f"WebSocket connected to {label}")
|
||||||
async for message in ws:
|
async for message in ws:
|
||||||
try:
|
try:
|
||||||
|
|||||||
Reference in New Issue
Block a user