push

Author: hassiebp

langfuse/_client/client.py

@@ -2722,6 +2722,9 @@ async def process_item(item: ExperimentItem) -> dict:
             except Exception as e:
                 langfuse_logger.error(f"Failed to store run evaluation: {e}")
 
+        # Flush scores and traces
+        self.flush()
+
         return {
             "item_results": valid_results,
             "run_evaluations": run_evaluations,

langfuse/_client/experiments.py

@@ -289,8 +289,8 @@ def __call__(
         *,
         input: Any,
         output: Any,
-        expected_output: Any = None,
-        metadata: Optional[Dict[str, Any]] = None,
+        expected_output: Any,
+        metadata: Optional[Dict[str, Any]],
         **kwargs: Dict[str, Any],
     ) -> Union[
         Evaluation, List[Evaluation], Awaitable[Union[Evaluation, List[Evaluation]]]