PR #30

Author: Andrei Bratu

src/humanloop/eval_utils/run.py

@@ -467,7 +467,7 @@ def upload_callback(log: dict):
         )
         start_time = datetime.now()
         try:
-            if datapoint_dict.get("messages"):
+            if "messages" in datapoint_dict and datapoint_dict["messages"] is not None:
                 # function_ is decorated by Humanloop, the OTel Exporter will
                 # handle the logging, which will call the upload_callback
                 # function above when it's done

src/humanloop/otel/exporter.py

@@ -84,10 +84,8 @@ def is_evaluated_file(
                 evaluation_context = None
             for span in spans:
                 if is_humanloop_span(span):
-                    # The thread doing the logging is different than the
-                    # thread spawned by eval_utils.run.run_eval. Need
-                    # to pass the EvaluationContext to the thread doing
-                    # the logging
+                    # We pass the EvaluationContext from the eval_run utility thread to
+                    # the export thread so the .log action works as expected
                     self._upload_queue.put(
                         (
                             span,