Update app.py

app.py

@@ -60,11 +60,15 @@ async def summarize_news(query, num_results=3):
         chunk_size = 500  # Adjust chunk size as needed
         chunks = [sentences[i:i + chunk_size] for i in range(0, len(sentences), chunk_size)]
 
-        # Summarize chunks concurrently
-        summaries = await asyncio.gather(*[summarizer(' '.join(chunk), max_length=120, min_length=30, do_sample=False) for chunk in chunks])
+        # Summarize each chunk separately
+        summaries = []
+        for chunk in chunks:
+            chunk_text = ' '.join(chunk)
+            summary = summarizer(chunk_text, max_length=120, min_length=30, do_sample=False)
+            summaries.append(summary[0]['summary_text'])
 
         # Combine all summaries
-        final_summary = ' '.join([summary[0]['summary_text'] for summary in summaries])
+        final_summary = ' '.join(summaries)
 
         logging.debug(f"Final summarized text: {final_summary}")
         return final_summary