File tree Expand file tree Collapse file tree 1 file changed +35
-0
lines changed Expand file tree Collapse file tree 1 file changed +35
-0
lines changed Original file line number Diff line number Diff line change 1+ from typing import Dict , List
2+
3+ import os
4+
5+ from dotenv import load_dotenv
6+
7+ from parea import Parea
8+ from parea .schemas import FilterOperator , QueryParams
9+
10+ load_dotenv ()
11+
12+
13+ project_name = "default"
14+ p = Parea (api_key = os .getenv ("PAREA_API_KEY" ), project_name = project_name )
15+
16+
17+ def fetch_trace_logs_as_jsonl () -> List [Dict ]:
18+ page_size = 100
19+ query_params = QueryParams (
20+ project_name = project_name ,
21+ filter_field = "trace_name" ,
22+ filter_value = "personalize_email_german" ,
23+ filter_operator = FilterOperator .EQUALS ,
24+ page_size = page_size ,
25+ status = 'success' ,
26+ )
27+ initial_fetch = p .get_trace_logs (query_params )
28+ fetched_trace_logs = initial_fetch .results
29+ for page in range (1 , initial_fetch .total_pages ):
30+ query_params .page = page
31+ fetched_trace_logs .extend (p .get_trace_logs (query_params ).results )
32+ return [trace_log .convert_to_jsonl_row_for_finetuning () for trace_log in fetched_trace_logs ]
33+
34+
35+ jsonl_rows = fetch_trace_logs_as_jsonl ()
You can’t perform that action at this time.
0 commit comments