From 181f83960e68c2651c47dbab883165d2f3ff582c Mon Sep 17 00:00:00 2001 From: Angus Jelinek Date: Thu, 12 Dec 2024 10:29:04 -0800 Subject: [PATCH] increase payload size to 20mb --- python/langsmith/_internal/_background_thread.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python/langsmith/_internal/_background_thread.py b/python/langsmith/_internal/_background_thread.py index 8e967d63e..54013c7a6 100644 --- a/python/langsmith/_internal/_background_thread.py +++ b/python/langsmith/_internal/_background_thread.py @@ -95,7 +95,7 @@ def _tracing_thread_drain_queue( def _tracing_thread_drain_compressed_buffer( - client: Client, size_limit: int = 100, size_limit_bytes: int = 65_536 + client: Client, size_limit: int = 100, size_limit_bytes: int = 20_971_520 ) -> Optional[io.BytesIO]: assert client.compressed_runs_buffer is not None assert client.compressor_writer is not None @@ -258,7 +258,7 @@ def tracing_control_thread_func_compress_parallel( batch_ingest_config = _ensure_ingest_config(client.info) size_limit: int = batch_ingest_config["size_limit"] - size_limit_bytes = batch_ingest_config.get("size_limit_bytes", 65_536) + size_limit_bytes = batch_ingest_config.get("size_limit_bytes", 20_971_520) assert size_limit_bytes is not None num_workers = min(4, os.cpu_count() or 1)