Update app.py

app.py

@@ -365,13 +365,14 @@ async def trade_setup():
 
 
 @time_logger
-async def get_google_news(queries):
+async def get_google_news(queries, max_results = 3):
     try:
         results=[]     ## checking
         task = []
         
         async def duckduckgo_search(query):
-            results = DDGS().news(query, max_results=10, timelimit="w")
+            query = query + "+blogs"
+            results = DDGS().news(query, max_results, timelimit="w")
             news = [{f"[{doc['title']}]({doc['url']})": doc['body'] for doc in results}]
             return news
             
@@ -391,7 +392,7 @@ async def get_google_news(queries):
 async def get_duckai_news(queries):
 
     task = []
-    results = await get_google_news(queries)
+    results = await get_google_news(queries,3)
     prompt = """#Instruction:
                 Summarise the impactful points of the news and mention the news link and date of publish at the end if available
                 #Format:
@@ -444,7 +445,7 @@ async def raw_news(raw_query, subqueries, todays_news_func_call, ticker):
     swot_analysis_link = f'https://widgets.trendlyne.com/web-widget/swot-widget/Poppins/{urllib.parse.quote(ticker)}/'
     tasks = [get_the_ticker_stat(ticker),
             get_the_ticker_news(ticker),
-            get_google_news(subqueries),
+            get_google_news(subqueries,10),
             scrape_webpage(swot_analysis_link)]
     try:
         ticker_stats, ticker_news, google_news, swot_analysis = await asyncio.gather(*tasks)
@@ -555,7 +556,7 @@ def generate_final_response(prompt, history):
             news_link.append(asyncio.run(get_duckai_news(subqueries)))
         elif chat_completion_params['todays_news_flag'] and len(ticker)>0:
             for tick in chat_completion_params["stock_name"]:
-                news_googles.append(f"Latest News for {tick}\n\n {asyncio.run(get_google_news(subqueries))}")
+                news_googles.append(f"Latest News for {tick}\n\n {asyncio.run(get_google_news(subqueries,10))}")
         elif (chat_completion_params['follow_up_query'] and ticker_stats != []) or (display_ticker == ticker and ticker_stats != []):
             # logging.info("\n\nAssigned into a followup query\n\n")
             chat_completion_params['follow_up_query'] = True