@@ -42,8 +42,8 @@ def _llama_index_query(args: argparse.Namespace) -> None:
4242 "node" : {
4343 "id" : node .node_id ,
4444 "text" : node .text ,
45- "metadata" : node .metadata if hasattr (node , ' metadata' ) else {}
46- }
45+ "metadata" : node .metadata if hasattr (node , " metadata" ) else {},
46+ },
4747 }
4848 if args .json :
4949 print (json .dumps (result , indent = 2 ))
@@ -60,7 +60,7 @@ def _llama_index_query(args: argparse.Namespace) -> None:
6060 "query" : args .query ,
6161 "top_k" : args .top_k ,
6262 "threshold" : args .threshold ,
63- "nodes" : []
63+ "nodes" : [],
6464 }
6565 print (json .dumps (result , indent = 2 ))
6666 exit (1 )
@@ -75,7 +75,7 @@ def _llama_index_query(args: argparse.Namespace) -> None:
7575 "query" : args .query ,
7676 "top_k" : args .top_k ,
7777 "threshold" : args .threshold ,
78- "nodes" : []
78+ "nodes" : [],
7979 }
8080 print (json .dumps (result , indent = 2 ))
8181 exit (1 )
@@ -85,14 +85,14 @@ def _llama_index_query(args: argparse.Namespace) -> None:
8585 "query" : args .query ,
8686 "top_k" : args .top_k ,
8787 "threshold" : args .threshold ,
88- "nodes" : []
88+ "nodes" : [],
8989 }
90- for node in nodes :
90+ for node in nodes : # type: ignore
9191 node_data = {
9292 "id" : node .node_id ,
9393 "score" : node .score ,
9494 "text" : node .text ,
95- "metadata" : node .metadata if hasattr (node , ' metadata' ) else {}
95+ "metadata" : node .metadata if hasattr (node , " metadata" ) else {},
9696 }
9797 result ["nodes" ].append (node_data )
9898
@@ -169,7 +169,7 @@ def _llama_stack_query(args: argparse.Namespace) -> None:
169169 "query" : args .query ,
170170 "top_k" : args .top_k ,
171171 "threshold" : args .threshold ,
172- "nodes" : []
172+ "nodes" : [],
173173 }
174174 print (json .dumps (result , indent = 2 ))
175175 exit (1 )
@@ -185,7 +185,7 @@ def _llama_stack_query(args: argparse.Namespace) -> None:
185185 "query" : args .query ,
186186 "top_k" : args .top_k ,
187187 "threshold" : args .threshold ,
188- "nodes" : []
188+ "nodes" : [],
189189 }
190190 print (json .dumps (result , indent = 2 ))
191191 exit (1 )
@@ -195,15 +195,15 @@ def _llama_stack_query(args: argparse.Namespace) -> None:
195195 "query" : args .query ,
196196 "top_k" : args .top_k ,
197197 "threshold" : args .threshold ,
198- "nodes" : []
198+ "nodes" : [],
199199 }
200200
201201 for _id , chunk , score in zip (md ["document_ids" ], md ["chunks" ], md ["scores" ]):
202202 node_data = {
203203 "id" : _id ,
204- "score" : score .score if hasattr (score , ' score' ) else score ,
204+ "score" : score .score if hasattr (score , " score" ) else score ,
205205 "text" : chunk ,
206- "metadata" : {}
206+ "metadata" : {},
207207 }
208208 result ["nodes" ].append (node_data )
209209
@@ -221,6 +221,7 @@ def _llama_stack_query(args: argparse.Namespace) -> None:
221221 # else:
222222 # print(content)
223223
224+
224225if __name__ == "__main__" :
225226 parser = argparse .ArgumentParser (
226227 description = "Utility script for querying RAG database"
@@ -263,15 +264,12 @@ def _llama_stack_query(args: argparse.Namespace) -> None:
263264 # In JSON mode, only show ERROR or higher to avoid polluting JSON output
264265 logging .basicConfig (
265266 level = logging .ERROR ,
266- format = ' %(levelname)s: %(message)s' ,
267- stream = sys .stderr # Send logs to stderr to keep stdout clean for JSON
267+ format = " %(levelname)s: %(message)s" ,
268+ stream = sys .stderr , # Send logs to stderr to keep stdout clean for JSON
268269 )
269270 else :
270271 # In normal mode, show info and above
271- logging .basicConfig (
272- level = logging .INFO ,
273- format = '%(message)s'
274- )
272+ logging .basicConfig (level = logging .INFO , format = "%(message)s" )
275273
276274 if not args .json :
277275 logging .info ("Command line used: " + " " .join (sys .argv ))
0 commit comments