@@ -208,9 +208,13 @@ def get_evaluation_rows_by_ids(
208208 fetched_runs : List [Any ] = []
209209 try :
210210 if run_ids :
211- fetched_runs .extend (list (self .client .list_runs (ids = run_ids , select = ["id" , "inputs" , "outputs" , "trace_id" ])) )
211+ fetched_runs .extend (
212+ list (self .client .list_runs (ids = run_ids , select = ["id" , "inputs" , "outputs" , "trace_id" ]))
213+ )
212214 if trace_ids :
213- fetched_runs .extend (list (self .client .list_runs (trace_ids = trace_ids , select = ["id" , "inputs" , "outputs" , "trace_id" ])) )
215+ fetched_runs .extend (
216+ list (self .client .list_runs (trace_ids = trace_ids , select = ["id" , "inputs" , "outputs" , "trace_id" ]))
217+ )
214218 except (AttributeError , ValueError , KeyError , TypeError ) as e :
215219 logger .warning ("Failed to fetch runs by ids: %s" , e )
216220 return []
@@ -232,7 +236,11 @@ def get_evaluation_rows_by_ids(
232236
233237 ep_messages : List [Message ] = []
234238 if isinstance (out , dict ) and isinstance (out .get ("messages" ), list ):
235- ep_messages .extend (self ._extract_messages_from_payload ({"messages" : out ["messages" ]}, include_tool_calls , is_output = True ))
239+ ep_messages .extend (
240+ self ._extract_messages_from_payload (
241+ {"messages" : out ["messages" ]}, include_tool_calls , is_output = True
242+ )
243+ )
236244 else :
237245 ep_messages .extend (self ._extract_messages_from_payload (inp , include_tool_calls ))
238246 ep_messages .extend (self ._extract_messages_from_payload (out , include_tool_calls , is_output = True ))
0 commit comments