Update app.py

app.py

@@ -7,7 +7,6 @@ from crewai_tools import PDFSearchTool, FileReadTool, DOCXSearchTool, CSVSearchT
 from langchain_google_genai import ChatGoogleGenerativeAI
 from langchain.agents.agent_types import AgentType
 from langchain_experimental.agents.agent_toolkits import create_csv_agent
-import asyncio
 
 # API keys-----------------move them to ENV 
 os.environ["OPENAI_API_KEY"] = "NA"
@@ -91,7 +90,7 @@ class tools:
 
 class AgentLoader:
 
-    async def csvReaderAgent(path):
+    def csvReaderAgent(path):
         agent = create_csv_agent(
             ChatGoogleGenerativeAI(temperature=0.6, model="gemini-1.5-flash-latest"),
             path,
@@ -100,7 +99,7 @@ class AgentLoader:
         )
         return agent
 
-    async def fileReaderAgent(path):
+    def fileReaderAgent(path):
         FileReader = Agent(
             role='File searcher',
             goal='To analyse and generate optimal and reliable results',
@@ -114,7 +113,7 @@ class AgentLoader:
         )
         return FileReader
     
-    async def PdfReaderAgent(path):
+    def PdfReaderAgent(path):
         PdfReader = Agent(
             role='PDF searcher',
             goal='To analyse and generate optimal and reliable results',
@@ -128,7 +127,7 @@ class AgentLoader:
         )
         return PdfReader
     
-    async def DocsReaderAgent(path):
+    def DocsReaderAgent(path):
         DocsReader = Agent(
             role='Docs searcher',
             goal='To analyse and generate optimal and reliable results',
@@ -142,11 +141,11 @@ class AgentLoader:
         )
         return DocsReader
     
-    async def writerAgent():
-        writer = Agent(
+    def writerAgent():
+        writer=Agent(
             role='Content Writer',
             goal='To produce higly accurate and easy to understand information',
-            backstory="""You are a content specialist and are responsible to generate reliable and easy to understand content or information based on the summary of data.
+            backstory="""You are an content specialist and are respinsible to generate reliable and easy to understand content or information based on the summary of data.
             You should provide indetail results on the summary data.""",
             verbose=True,
             llm=llm
@@ -156,18 +155,16 @@ class AgentLoader:
 #<------------------------------Agents END------------------------->
 
 #<-------------------------------Tasks---------------------------->
-async def getTasks(query, agent, exp):
-    task_read = Task(
+def getTasks(query, agent, exp):
+    task_read=Task(
         description=f'{query}',
         agent=agent,
         expected_output=f'A detailed information on {query}'
     )
 
-    writer_agent = await AgentLoader.writerAgent()
-    
-    task_write = Task(
+    task_write=Task(
         description=f'{query}',
-        agent=writer_agent,
+        agent=AgentLoader.writerAgent(),
         expected_output=exp
     )
 
@@ -176,32 +173,29 @@ async def getTasks(query, agent, exp):
 # Gradio interface function
 def process_file(file, query, expected_output):
     path = file.name
-
-    async def process_async():
-        if path.endswith(".pdf"):
-            agent = await AgentLoader.PdfReaderAgent(path)
-        elif path.endswith(".docx"):
-            agent = await AgentLoader.DocsReaderAgent(path)
-        elif path.endswith(".json") or path.endswith(".txt"):
-            agent = await AgentLoader.fileReaderAgent(path)
-        elif path.endswith(".csv"):
-            agent = await AgentLoader.csvReaderAgent(path)
-            results = agent.run(query)
-            return results
-        else:
-            return 'File NOT supported'
-
-        tasks = await getTasks(query, agent, expected_output)
+    
+    if path.endswith(".pdf"):
+        agent = AgentLoader.PdfReaderAgent(path)
+    elif path.endswith(".docx"):
+        agent = AgentLoader.DocsReaderAgent(path)
+    elif path.endswith(".json") or path.endswith(".txt"):
+        agent = AgentLoader.fileReaderAgent(path)
+    elif path.endswith(".csv"):
+        agent = AgentLoader.csvReaderAgent(path)
+        results = agent.run(query)
+    else:
+        return 'File NOT supported'
+    
+    if not path.endswith(".csv"):
+        task1 = getTasks(query, agent, expected_output)
         mycrew = Crew(
-            agents=[agent, await AgentLoader.writerAgent()],
-            tasks=tasks,
+            agents=[agent, AgentLoader.writerAgent()],
+            tasks=task1,
             verbose=True
         )
         results = mycrew.kickoff()
-        return results
-
-    loop = asyncio.get_event_loop()
-    return loop.run_until_complete(process_async())
+    
+    return results
 
 # Create the Gradio interface
 interface = gr.Interface(