From 0593cc1376eda0dcb878297c1eb636271eaabdfc Mon Sep 17 00:00:00 2001 From: Ankush Gola Date: Thu, 12 Dec 2024 00:04:20 -0800 Subject: [PATCH] fix --- python/langsmith/client.py | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/python/langsmith/client.py b/python/langsmith/client.py index d03153f84..e67c106ff 100644 --- a/python/langsmith/client.py +++ b/python/langsmith/client.py @@ -494,13 +494,10 @@ def __init__( if info is None or isinstance(info, ls_schemas.LangSmithInfo) else ls_schemas.LangSmithInfo(**info) ) - self.compressed_multipart_buffer = ... weakref.finalize(self, close_session, self.session) atexit.register(close_session, session_) # Initialize auto batching - if auto_batch_tracing and _compression_enabled: - ... - elif auto_batch_tracing: + if auto_batch_tracing: self.tracing_queue: Optional[PriorityQueue] = PriorityQueue() threading.Thread( @@ -1298,10 +1295,6 @@ def create_run( self.tracing_queue.put( TracingQueueItem(run_create["dotted_order"], serialized_op) ) - elif os.environ["COMP"]: - # Do something different - # Use existing serialized_run_dict - else: # Neither Rust nor Python batch ingestion is configured, # fall back to the non-batch approach.