Fix

langchain-ai · Oct 1, 2024 · 12c110f · 12c110f
1 parent a1f100e
commit 12c110f
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/python/langsmith/client.py b/python/langsmith/client.py
@@ -5825,10 +5825,9 @@ 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"]
-    if multipart_override := os.getenv("LANGSMITH_FF_MULTIPART"):
-        use_multipart = multipart_override.lower() in ["1", "true"]
-    else:
-        use_multipart = batch_ingest_config.get("use_multipart_endpoint", False)
+    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
 
     sub_threads: List[threading.Thread] = []
     # 1 for this func, 1 for getrefcount, 1 for _get_data_type_cached