cloud qdrant restore

app.py

@@ -46,48 +46,48 @@ scheduler = CommitScheduler(
 # We need to create the local vectorstore collection once using load_chunks
 # vectorestore colection are stored on persistent storage so this needs to be run only once
 # hence, comment out line below when creating for first time
-vectorstores = load_new_chunks()
+# vectorstores = load_new_chunks()
 # once the vectore embeddings  are created we will use qdrant client to access these
-vectorstores = get_local_qdrant()
+# vectorstores = get_local_qdrant()
 
 # Configure cloud Qdrant client #TESTING
-# def get_cloud_qdrant():
-#     from langchain_community.embeddings import HuggingFaceEmbeddings
-#     from langchain_community.vectorstores import Qdrant
-#     from torch import cuda
+def get_cloud_qdrant():
+    from langchain_community.embeddings import HuggingFaceEmbeddings
+    from langchain_community.vectorstores import Qdrant
+    from torch import cuda
     
-#     # Get config and setup embeddings like in process_chunks.py
-#     model_config = getconfig("model_params.cfg")
-#     device = 'cuda' if cuda.is_available() else 'cpu'
+    # Get config and setup embeddings like in process_chunks.py
+    model_config = getconfig("model_params.cfg")
+    device = 'cuda' if cuda.is_available() else 'cpu'
     
-#     embeddings = HuggingFaceEmbeddings(
-#         model_kwargs = {'device': device},
-#         encode_kwargs = {'normalize_embeddings': True},
-#         model_name=model_config.get('retriever','MODEL')
-#     )
+    embeddings = HuggingFaceEmbeddings(
+        model_kwargs = {'device': device},
+        encode_kwargs = {'normalize_embeddings': True},
+        model_name=model_config.get('retriever','MODEL')
+    )
     
-#     # Get Qdrant API key from environment variable
-#     qdrant_api_key = os.getenv("QDRANT")
-#     if not qdrant_api_key:
-#         raise ValueError("QDRANT API key not found in environment variables")
+    # Get Qdrant API key from environment variable
+    qdrant_api_key = os.getenv("QDRANT")
+    if not qdrant_api_key:
+        raise ValueError("QDRANT API key not found in environment variables")
     
-#     # Create the Qdrant client
-#     client = QdrantClient(
-#         url="https://ff3f0448-0a00-470e-9956-49efa3071db3.europe-west3-0.gcp.cloud.qdrant.io:6333", 
-#         api_key=qdrant_api_key,
-#     )
+    # Create the Qdrant client
+    client = QdrantClient(
+        url="https://ff3f0448-0a00-470e-9956-49efa3071db3.europe-west3-0.gcp.cloud.qdrant.io:6333", 
+        api_key=qdrant_api_key,
+    )
     
-#     # Wrap the client in Langchain's Qdrant vectorstore
-#     vectorstore = Qdrant(
-#         client=client,
-#         collection_name="allreports",
-#         embeddings=embeddings,
-#     )
+    # Wrap the client in Langchain's Qdrant vectorstore
+    vectorstore = Qdrant(
+        client=client,
+        collection_name="allreports",
+        embeddings=embeddings,
+    )
     
-#     return {"allreports": vectorstore}
+    return {"allreports": vectorstore}
 
-# # Replace local Qdrant with cloud Qdrant
-# vectorstores = get_cloud_qdrant()
+# Replace local Qdrant with cloud Qdrant
+vectorstores = get_cloud_qdrant()
 
 #####---------------------CHAT-----------------------------------------------------
 def start_chat(query,history):