v0.1.2

src/baseInfra/dbInterface.py

@@ -89,6 +89,7 @@ class DbInterface:
         #             retVal=True
         # #cache.append({'input':input,'value':value})
         cache={'input':input,'value':value}
+        print(f"Adding to cache the results {value} for {input}")
         fb.patch(self.base_dir+"/"+self.cache_loc, {fb_key:cache})
         return retVal
     

src/main.py

@@ -77,6 +77,23 @@ async def get_matching_docs(inStr: str, kwargs: Dict [Any, Any] ,background_task
     logger.info("================================================")
     return retVal
 
+@app.post(api_base+"/getMatchingDocsSync")
+async def get_matching_docs_sync(inStr: str, kwargs: Dict [Any, Any]) -> Any:
+    """
+    Gets the query embeddings and uses metadata appropriately and gets the matching docs for query
+    This is synchronous version
+    TODO: Add parameter for type of query and number of docs to return
+    TODO: Add parameter to return the source information as well
+    """
+    logger.info("================================================")
+    logger.info("Received new request at /getMatchingDocs:"+inStr)
+    retVal=await chromaIntf.getRelevantDocs(inStr,kwargs)
+    #background_tasks.add_task(chromaIntf.getRelevantDocs,inStr,kwargs)
+    #retVal="added to queue"
+    logger.info("Returning:"+retVal)
+    logger.info("================================================")
+    return retVal
+
 @app.post(api_base+"/addTextDocument")
 async def add_text_document(inDoc: DocWithMeta ) -> Any:
     """
@@ -122,5 +139,5 @@ async def list_docs():
 print(__name__)
 
 if __name__ == '__main__' or __name__ == "src.main":
-    uvicorn.run(f"{Path(__file__).stem}:app", host="0.0.0.0", port=8000,workers=2)
+    uvicorn.run(f"{Path(__file__).stem}:app", host="0.0.0.0", port=8000,workers=1)
     #uvicorn.run(app, host="0.0.0.0", port=8000)