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.