From 8222c6629d2f78bd8df3f8797a9d50083b3b67c6 Mon Sep 17 00:00:00 2001 From: Debanjum Singh Solanky Date: Sat, 12 Oct 2024 10:45:39 -0700 Subject: [PATCH] Remove unused subscribed argument to read_webpage function --- src/khoj/processor/tools/online_search.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/src/khoj/processor/tools/online_search.py b/src/khoj/processor/tools/online_search.py index cbb7f302..16539b5c 100644 --- a/src/khoj/processor/tools/online_search.py +++ b/src/khoj/processor/tools/online_search.py @@ -102,7 +102,7 @@ async def search_online( async for event in send_status_func(f"**Reading web pages**: {webpage_links_str}"): yield {ChatEvent.STATUS: event} tasks = [ - read_webpage_and_extract_content(subquery, link, content, subscribed=subscribed, user=user, agent=agent) + read_webpage_and_extract_content(subquery, link, content, user=user, agent=agent) for link, subquery, content in webpages ] results = await asyncio.gather(*tasks) @@ -158,9 +158,7 @@ async def read_webpages( webpage_links_str = "\n- " + "\n- ".join(list(urls)) async for event in send_status_func(f"**Reading web pages**: {webpage_links_str}"): yield {ChatEvent.STATUS: event} - tasks = [ - read_webpage_and_extract_content(query, url, subscribed=subscribed, user=user, agent=agent) for url in urls - ] + tasks = [read_webpage_and_extract_content(query, url, user=user, agent=agent) for url in urls] results = await asyncio.gather(*tasks) response: Dict[str, Dict] = defaultdict(dict) @@ -171,7 +169,7 @@ async def read_webpages( async def read_webpage_and_extract_content( - subquery: str, url: str, content: str = None, subscribed: bool = False, user: KhojUser = None, agent: Agent = None + subquery: str, url: str, content: str = None, user: KhojUser = None, agent: Agent = None ) -> Tuple[str, Union[None, str], str]: try: if is_none_or_empty(content):