anubhav77 commited on
Commit
0756fa3
·
1 Parent(s): 4e1b239
Files changed (2) hide show
  1. src/chroma_intf.py +17 -8
  2. src/main.py +2 -2
src/chroma_intf.py CHANGED
@@ -23,7 +23,7 @@ embedding = HuggingFaceBgeEmbeddings(
23
 
24
  persist_directory = 'db'
25
  try:
26
- dbh.restoreFolder("./db")
27
  except:
28
  print("Probably folder doesn't exist as it is brand new setup")
29
  docs = [
@@ -121,13 +121,22 @@ def getRelevantDocs(query:str):
121
  """This should also post the result to firebase"""
122
  retVal=retriever.get_relevant_documents(query)
123
  value=[]
124
- for item in retVal:
125
- v="Info:"+item['page_content']+" "
126
- for key in item.metadata.keys():
127
- if key != "ID":
128
- v+=key+":"+item.metadata[key]+" "
129
- value.append(v)
130
- db_interface.add_to_cache(input=query,value=value)
 
 
 
 
 
 
 
 
 
131
  return retVal
132
 
133
 
 
23
 
24
  persist_directory = 'db'
25
  try:
26
+ dbh.restoreFolder("db")
27
  except:
28
  print("Probably folder doesn't exist as it is brand new setup")
29
  docs = [
 
121
  """This should also post the result to firebase"""
122
  retVal=retriever.get_relevant_documents(query)
123
  value=[]
124
+ try:
125
+ for item in retVal:
126
+ v="Info:"+item['page_content']+" "
127
+ for key in item.metadata.keys():
128
+ if key != "ID":
129
+ v+=key+":"+item.metadata[key]+" "
130
+ value.append(v)
131
+ db_interface.add_to_cache(input=query,value=value)
132
+ except:
133
+ for item in retVal:
134
+ v="Info:"+item.page_content+" "
135
+ for key in item.metadata.keys():
136
+ if key != "ID":
137
+ v+=key+":"+item.metadata[key]+" "
138
+ value.append(v)
139
+ db_interface.add_to_cache(input=query,value=value)
140
  return retVal
141
 
142
 
src/main.py CHANGED
@@ -58,11 +58,11 @@ async def add_text_document(inStr: str,metadata: dict ) -> Any:
58
  @app.get(api_base+"/persist")
59
  async def persist_db():
60
  persist()
61
- return await dbh.backupFolder("./db")
62
 
63
  @app.get(api_base+"/reset")
64
  async def reset_db():
65
- return await dbh.restoreFolder("./db")
66
 
67
  print(__name__)
68
 
 
58
  @app.get(api_base+"/persist")
59
  async def persist_db():
60
  persist()
61
+ return await dbh.backupFolder("db")
62
 
63
  @app.get(api_base+"/reset")
64
  async def reset_db():
65
+ return await dbh.restoreFolder("db")
66
 
67
  print(__name__)
68