[Python] Catch on each write endpoint (#936)

langchain-ai · Aug 22, 2024 · 15b7ea6 · 15b7ea6
1 parent f792a58
commit 15b7ea6
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/python/langsmith/client.py b/python/langsmith/client.py
@@ -1381,8 +1381,8 @@ def batch_ingest_runs(
             self._post_batch_ingest_runs(orjson.dumps(body_chunks))
 
     def _post_batch_ingest_runs(self, body: bytes):
-        try:
-            for api_url, api_key in self._write_api_urls.items():
+        for api_url, api_key in self._write_api_urls.items():
+            try:
                 self.request_with_retries(
                     "POST",
                     f"{api_url}/runs/batch",
@@ -1396,8 +1396,8 @@ def _post_batch_ingest_runs(self, body: bytes):
                     to_ignore=(ls_utils.LangSmithConflictError,),
                     stop_after_attempt=3,
                 )
-        except Exception as e:
-            logger.warning(f"Failed to batch ingest runs: {repr(e)}")
+            except Exception as e:
+                logger.warning(f"Failed to batch ingest runs: {repr(e)}")
 
     def update_run(
         self,

diff --git a/python/pyproject.toml b/python/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "langsmith"
-version = "0.1.101"
+version = "0.1.102"
 description = "Client library to connect to the LangSmith LLM Tracing and Evaluation Platform."
 authors = ["LangChain <support@langchain.dev>"]
 license = "MIT"