dont close buffer

langchain-ai · Dec 9, 2024 · 3888d15 · 3888d15
1 parent 56278b6
commit 3888d15
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/python/langsmith/_internal/_operations.py b/python/langsmith/_internal/_operations.py
@@ -338,7 +338,7 @@ def compress_multipart_stream(
         parts_and_contexts: MultipartPartsAndContext,
     ) -> Iterator[bytes]:
         # Create a streaming compressor context
-        compressor = self.compressor.stream_writer(self.buffer)
+        compressor = self.compressor.stream_writer(self.buffer, closefd=False)
 
         try:
             for part_name, (filename, data, content_type, headers) in (
@@ -383,7 +383,7 @@ def compress_multipart_stream(
             # Yield any final compressed data
             yield from self._yield_and_reset_buffer()
             # Close the buffer
-            self.buffer.close()
+            # self.buffer.close()
 
     def compress_operations(
         self,