minor changes

LLM.py

@@ -4,35 +4,6 @@ from config import (
     query_gen_api_key_1, query_gen_api_key_2, query_gen_api_key_3, query_gen_api_key_4
 )
 
-import json
-import threading
-import datetime
-from pathlib import Path
-
-# Thread-safe writer
-_log_lock = threading.Lock()
-LOG_PATH = Path("qa_pipeline_log.jsonl")  # adjust path as needed
-
-def log_qa_entry(
-    original_question: str,
-    generated_search_query: str,
-    retrieved_context: str,
-    final_answer: str,
-    extra: dict = None
-):
-    entry = {
-        "timestamp_utc": datetime.datetime.utcnow().isoformat() + "Z",
-        "original_question": original_question,
-        "search_query": generated_search_query,
-        "context": retrieved_context,
-        "answer": final_answer,
-    }
-    if extra:
-        entry.update(extra)
-    line = json.dumps(entry, ensure_ascii=False)
-    with _log_lock:
-        with open(LOG_PATH, "a", encoding="utf-8") as f:
-            f.write(line + "\n")
 
 
 from typing import List
@@ -153,16 +124,6 @@ def process_user_queries_with_context(user_inputs: List[str]) -> List[str]:
     contexts = get_context_for_questions(search_queries)
     prompts = construct_prompts(user_inputs, contexts)
     answers = generate_answers(prompts)
-
-    # Logging each triplet
-    for orig_q, search_q, context, ans in zip(user_inputs, search_queries, contexts, answers):
-        log_qa_entry(
-            original_question=orig_q,
-            generated_search_query=search_q,
-            retrieved_context=context,
-            final_answer=ans,
-        )
-
     return answers
 
 if __name__=="__main__":

app.py

@@ -79,5 +79,5 @@ async def run_hackrx(
         f"Response ready: path={request.url.path} method={request.method} "
         f"received_at={received_at.isoformat()}Z sent_at={sent_at.isoformat()}Z duration_s={duration:.3f}"
     )
-
+    print(answers)
     return {"answers": answers}