Update app.py

app.py

@@ -143,10 +143,10 @@ class AgentLoader:
         return DocsReader
     
     async def writerAgent():
-        writer=Agent(
+        writer = Agent(
             role='Content Writer',
             goal='To produce higly accurate and easy to understand information',
-            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.
+            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.
             You should provide indetail results on the summary data.""",
             verbose=True,
             llm=llm
@@ -156,16 +156,18 @@ class AgentLoader:
 #<------------------------------Agents END------------------------->
 
 #<-------------------------------Tasks---------------------------->
-def getTasks(query, agent, exp):
-    task_read=Task(
+async def getTasks(query, agent, exp):
+    task_read = Task(
         description=f'{query}',
         agent=agent,
         expected_output=f'A detailed information on {query}'
     )
 
-    task_write=Task(
+    writer_agent = await AgentLoader.writerAgent()
+    
+    task_write = Task(
         description=f'{query}',
-        agent=AgentLoader.writerAgent(),
+        agent=writer_agent,
         expected_output=exp
     )
 
@@ -174,29 +176,32 @@ def getTasks(query, agent, exp):
 # Gradio interface function
 def process_file(file, query, expected_output):
     path = file.name
-    
-    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)
+
+    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)
         mycrew = Crew(
-            agents=[agent, AgentLoader.writerAgent()],
-            tasks=task1,
+            agents=[agent, await AgentLoader.writerAgent()],
+            tasks=tasks,
             verbose=True
         )
         results = mycrew.kickoff()
-    
-    return results
+        return results
+
+    loop = asyncio.get_event_loop()
+    return loop.run_until_complete(process_async())
 
 # Create the Gradio interface
 interface = gr.Interface(
@@ -213,4 +218,3 @@ interface = gr.Interface(
 
 # Launch the Gradio interface
 interface.launch()
-