Self ping

orchestrator_functions.py

@@ -494,7 +494,7 @@ def langchain_csv_chart(csv_url: str, question: str, chart_required: bool):
 async def csv_chat(csv_url: str, query: str):
     """
     Generate a response based on the provided CSV URL and query.
-    Prioritizes LangChain-Gemini, then LangChain-Groq, and finally raw Groq as fallback.
+    Prioritizes LangChain-Groq, then raw Groq, and finally LangChain-Gemini as fallback.
     
     Parameters:
     - csv_url (str): The URL of the CSV file.
@@ -512,52 +512,52 @@ async def csv_chat(csv_url: str, query: str):
     try:
         updated_query = f"{query} and Do not show any charts or graphs."
         
-        # --- 1. First Attempt: LangChain Gemini ---
+        # --- 1. First Attempt: LangChain Groq ---
         try:
-            gemini_answer = await asyncio.to_thread(
-                langchain_gemini_csv_handler, csv_url, updated_query, False
+            lang_groq_answer = await asyncio.to_thread(
+                langchain_csv_chat, csv_url, updated_query, False
             )
-            logger.info("LangChain-Gemini answer:", gemini_answer)
+            logger.info("LangChain-Groq answer:", lang_groq_answer)
             
-            if gemini_answer is not None:
-                return {"answer": jsonable_encoder(gemini_answer)}
+            if lang_groq_answer is not None:
+                return {"answer": jsonable_encoder(lang_groq_answer)}
             
-            raise Exception("LangChain-Gemini response not usable, falling back to LangChain-Groq")
+            raise Exception("LangChain-Groq response not usable, falling back to raw Groq")
             
-        except Exception as gemini_error:
-            logger.info(f"LangChain-Gemini error: {str(gemini_error)}")
+        except Exception as lang_groq_error:
+            logger.info(f"LangChain-Groq error: {str(lang_groq_error)}")
             
-            # --- 2. Second Attempt: LangChain Groq ---
+            # --- 2. Second Attempt: Raw Groq Chat ---
             try:
-                lang_groq_answer = await asyncio.to_thread(
-                    langchain_csv_chat, csv_url, updated_query, False
-                )
-                logger.info("LangChain-Groq answer:", lang_groq_answer)
+                raw_groq_answer = await asyncio.to_thread(groq_chat, csv_url, updated_query)
+                logger.info("Raw Groq answer:", raw_groq_answer)
                 
-                if lang_groq_answer is not None:
-                    return {"answer": jsonable_encoder(lang_groq_answer)}
+                if process_answer(raw_groq_answer) == "Empty response received." or raw_groq_answer is None:
+                    raise Exception("Raw Groq response not usable, falling back to LangChain-Gemini")
                 
-                raise Exception("LangChain-Groq response not usable, falling back to raw Groq")
+                if process_answer(raw_groq_answer):
+                    raise Exception("Raw Groq response not usable, falling back to LangChain-Gemini")
                 
-            except Exception as lang_groq_error:
-                logger.info(f"LangChain-Groq error: {str(lang_groq_error)}")
+                return {"answer": jsonable_encoder(raw_groq_answer)}
                 
-                # --- 3. Final Attempt: Raw Groq Chat ---
+            except Exception as raw_groq_error:
+                logger.info(f"Raw Groq error: {str(raw_groq_error)}")
+                
+                # --- 3. Final Attempt: LangChain Gemini ---
                 try:
-                    raw_groq_answer = await asyncio.to_thread(groq_chat, csv_url, updated_query)
-                    logger.info("Raw Groq answer:", raw_groq_answer)
-                    
-                    if process_answer(raw_groq_answer) == "Empty response received." or raw_groq_answer is None:
-                        return {"answer": "Sorry, I couldn't find relevant data..."}
+                    gemini_answer = await asyncio.to_thread(
+                        langchain_gemini_csv_handler, csv_url, updated_query, False
+                    )
+                    logger.info("LangChain-Gemini answer:", gemini_answer)
                     
-                    if process_answer(raw_groq_answer):
-                        raise Exception("All fallbacks exhausted")
+                    if gemini_answer is not None:
+                        return {"answer": jsonable_encoder(gemini_answer)}
                     
-                    return {"answer": jsonable_encoder(raw_groq_answer)}
+                    raise Exception("All fallbacks exhausted")
                     
-                except Exception as raw_groq_error:
-                    logger.info(f"Raw Groq error: {str(raw_groq_error)}")
-                    return {"answer": "error"}
+                except Exception as gemini_error:
+                    logger.info(f"LangChain-Gemini error: {str(gemini_error)}")
+                    return {"answer": "Sorry, I couldn't find relevant data..."}
                 
     except Exception as e:
         logger.info(f"Unexpected error: {str(e)}")
@@ -569,7 +569,6 @@ async def csv_chat(csv_url: str, query: str):
 
 
 
-
 async def csv_chart(csv_url: str, query: str):
     """
     Generate a chart based on the provided CSV URL and query.