diff --git a/python/langsmith/client.py b/python/langsmith/client.py index 8c36c7aea..d0c57f8a2 100644 --- a/python/langsmith/client.py +++ b/python/langsmith/client.py @@ -5795,7 +5795,6 @@ def _tracing_thread_handle_batch( _AUTO_SCALE_UP_NTHREADS_LIMIT = 16 _AUTO_SCALE_DOWN_NEMPTY_TRIGGER = 4 _BLOCKSIZE_BYTES = 1024 * 1024 # 1MB -_USE_MULTIPART = os.getenv("LANGSMITH_FF_MULTIPART") in ["1", "true"] def _ensure_ingest_config( @@ -5829,7 +5828,7 @@ def _tracing_control_thread_func(client_ref: weakref.ref[Client]) -> None: size_limit: int = batch_ingest_config["size_limit"] scale_up_nthreads_limit: int = batch_ingest_config["scale_up_nthreads_limit"] scale_up_qsize_trigger: int = batch_ingest_config["scale_up_qsize_trigger"] - use_multipart = _USE_MULTIPART + use_multipart = os.getenv("LANGSMITH_FF_MULTIPART") in ["1", "true"] # use_multipart = batch_ingest_config.get("use_multipart_endpoint", False) # TODO replace FF with reading from batch_ingest_config