Update app.py

app.py

@@ -7,6 +7,9 @@ from openai import OpenAI
 from langchain_community.embeddings.sentence_transformer import SentenceTransformerEmbeddings
 from langchain_community.vectorstores import Chroma
 
+from huggingface_hub import CommitScheduler
+from pathlib import Path
+
 
 client = OpenAI(
     base_url="https://api.endpoints.anyscale.com/v1",
@@ -28,6 +31,19 @@ retriever = vectorstore_persisted.as_retriever(
     search_kwargs={'k': 5}
 )
 
+# Prepare the logging functionality
+
+log_file = Path("logs/") / f"data_{uuid.uuid4()}.json"
+log_folder = log_file.parent
+
+scheduler = CommitScheduler(
+    repo_id="document-qna-chroma-anyscale-docs",
+    repo_type="dataset",
+    folder_path=log_folder,
+    path_in_repo="data",
+    every=2
+)
+
 qna_system_message = """
 You are an assistant to a financial services firm who answers user queries on annual reports.
 Users will ask questions delimited by triple backticks, that is, ```.
@@ -73,7 +89,21 @@ def predict(user_input):
 
     except Exception as e:
         prediction = e
-        
+
+    # While the prediction is made, log both the inputs and outputs to a local log file
+    # While writing to the log file, ensure that the commit scheduler is locked to avoid parallel
+    # access
+    
+    with scheduler.lock:
+        with log_file.open("a") as f:
+            f.write(json.dumps(
+                {
+                    'user_input': user_input,
+                    'model_response': prediction
+                }
+            ))
+            f.write("\n")
+    
     return prediction