put middle orchestrator

controller.py

@@ -317,21 +317,21 @@ async def csv_chat(request: Dict, authorization: str = Header(None)):
             return {"answer": jsonable_encoder(orchestrator_answer)}
 
         # Process with groq_chat first
-        # groq_answer = await asyncio.to_thread(groq_chat, decoded_url, query)
-        # logger.info("groq_answer:", groq_answer)
+        groq_answer = await asyncio.to_thread(groq_chat, decoded_url, query)
+        logger.info("groq_answer:", groq_answer)
         
-        # if process_answer(groq_answer) == "Empty response received.":
-        #     return {"answer": "Sorry, I couldn't find relevant data..."}
-
-        # if process_answer(groq_answer):
-        #     lang_answer = await asyncio.to_thread(
-        #         langchain_csv_chat, decoded_url, query, False
-        #     )
-        #     if process_answer(lang_answer):
-        #         return {"answer": "error"}
-        #     return {"answer": jsonable_encoder(lang_answer)}
-
-        # return {"answer": jsonable_encoder(groq_answer)}
+        if process_answer(groq_answer) == "Empty response received.":
+            return {"answer": "Sorry, I couldn't find relevant data..."}
+
+        if process_answer(groq_answer):
+            lang_answer = await asyncio.to_thread(
+                langchain_csv_chat, decoded_url, query, False
+            )
+            if process_answer(lang_answer):
+                return {"answer": "error"}
+            return {"answer": jsonable_encoder(lang_answer)}
+
+        return {"answer": jsonable_encoder(groq_answer)}
 
     except Exception as e:
         logger.error(f"Error processing request: {str(e)}")