Update app.py

app.py

@@ -8,7 +8,6 @@ from langchain_google_genai import ChatGoogleGenerativeAI
 from langchain.agents.agent_types import AgentType
 from langchain_experimental.agents.agent_toolkits import create_csv_agent
 from langchain_groq import ChatGroq
-import asyncio
 
 # API keys-----------------move them to ENV 
 os.environ["OPENAI_API_KEY"] = "NA"
@@ -26,9 +25,9 @@ class tools:
         PDFtool = PDFSearchTool(
             config=dict(
                 llm=dict(
-                    provider="google",
+                    provider="ollama",
                     config=dict(
-                        model="gemini-1.5-flash-latest",
+                        model="llama3-70b-8192",
                     ),
                 ),
                 embedder=dict(
@@ -47,9 +46,9 @@ class tools:
         Filetool = FileReadTool(
             config=dict(
                 llm=dict(
-                    provider="google",
+                    provider="ollama",
                     config=dict(
-                        model="gemini-1.5-flash-latest",
+                        model="llama3-70b-8192",
                     ),
                 ),
                 embedder=dict(
@@ -68,9 +67,9 @@ class tools:
         Docstool = DOCXSearchTool(
             config=dict(
                 llm=dict(
-                    provider="google",
+                    provider="ollama",
                     config=dict(
-                        model="gemini-1.5-flash-latest",
+                        model="llama3-70b-8192",
                     ),
                 ),
                 embedder=dict(
@@ -92,7 +91,7 @@ class AgentLoader:
 
     def csvReaderAgent(path):
         agent = create_csv_agent(
-            ChatGoogleGenerativeAI(temperature=0.6, model="gemini-1.5-flash-latest"),
+           ChatGroq(temperature=0.6, model="llama3-70b-8192"),
             path,
             verbose=True,
             agent_type=AgentType.ZERO_SHOT_REACT_DESCRIPTION
@@ -173,7 +172,7 @@ def getTasks(query, agent, exp):
     return [task_read, task_write]
 
 # Gradio interface function
-async def process_file(file, query, expected_output):
+def process_file(file, query, expected_output):
     path = file.name
     
     if path.endswith(".pdf"):
@@ -184,7 +183,7 @@ async def process_file(file, query, expected_output):
         agent = AgentLoader.fileReaderAgent(path)
     elif path.endswith(".csv"):
         agent = AgentLoader.csvReaderAgent(path)
-        results = await anyio.to_thread.run_sync(agent.run, query)
+        results = agent.run(query)
     else:
         return 'File NOT supported'
     
@@ -195,7 +194,7 @@ async def process_file(file, query, expected_output):
             tasks=task1,
             verbose=True
         )
-        results = await anyio.to_thread.run_sync(mycrew.kickoff)
+        results = mycrew.kickoff()
     
     return results