File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed
Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -167,7 +167,16 @@ def _load_data():
167167 elif len (output_rows ) == 1 : # Return the Langfuse row
168168 langfuse_row = output_rows [0 ]
169169 langfuse_row .input_metadata .completion_params = row .input_metadata .completion_params
170+ # merge dataset_info dicts on input_metadata
171+ if langfuse_row .input_metadata .dataset_info and row .input_metadata .dataset_info :
172+ langfuse_row .input_metadata .dataset_info = {
173+ ** row .input_metadata .dataset_info ,
174+ ** langfuse_row .input_metadata .dataset_info ,
175+ }
176+ elif row .input_metadata .dataset_info :
177+ langfuse_row .input_metadata .dataset_info = row .input_metadata .dataset_info
170178 langfuse_row .eval_metadata = row .eval_metadata
179+ langfuse_row .ground_truth = row .ground_truth
171180 return langfuse_row
172181 else :
173182 raise ValueError ("RemoteRolloutProcessor's output_data_loader should return exactly one row." )
You can’t perform that action at this time.
0 commit comments