PR feedback

Author: Andrei Bratu

poetry.lock

@@ -35,7 +35,7 @@ Repository = 'https://github.com/humanloop/humanloop-python'
 
 [tool.poetry.dependencies]
 python = ">=3.9,<4"
-deepdiff = "^6.7.1"
+deepdiff = "^8.2.0"
 httpx = ">=0.21.2"
 httpx-sse = "0.4.0"
 mmh3 = "^5.1.0"

pyproject.toml

@@ -19,7 +19,7 @@
 import time
 import types
 import typing
-from concurrent.futures import ThreadPoolExecutor, as_completed
+from concurrent.futures import ThreadPoolExecutor
 from datetime import datetime
 from functools import partial
 from logging import INFO
@@ -367,15 +367,8 @@ def upload_callback(log_id: str):
                 )
 
         with ThreadPoolExecutor(max_workers=workers) as executor:
-            futures = []
             for datapoint in hl_dataset.datapoints:
-                futures.append(executor.submit(_process_datapoint, datapoint))
-            # Program hangs if any uncaught exceptions are not handled here
-            for future in as_completed(futures):
-                try:
-                    future.result()
-                except Exception:
-                    pass
+                executor.submit(_process_datapoint, datapoint)
 
     stats = _wait_for_evaluation_to_complete(
         client=client,