diff --git a/src/khoj/routers/api_chat.py b/src/khoj/routers/api_chat.py index 43cc2512..68e7ea43 100644 --- a/src/khoj/routers/api_chat.py +++ b/src/khoj/routers/api_chat.py @@ -923,9 +923,7 @@ async def event_generator( # Automated tasks are handled before to allow mixing them with other conversation commands cmds_to_rate_limit = [] - is_automated_task = False if q.startswith("/automated_task"): - is_automated_task = True q = q.replace("/automated_task", "").lstrip() cmds_to_rate_limit += [ConversationCommand.AutomatedTask] @@ -985,7 +983,6 @@ async def event_generator( chosen_io = await aget_data_sources_and_output_format( q, chat_history, - is_automated_task, user=user, query_images=uploaded_images, agent=agent, @@ -1017,7 +1014,6 @@ async def event_generator( return defiltered_query = defilter_query(q) - file_filters = conversation.file_filters if conversation and conversation.file_filters else [] if conversation_commands == [ConversationCommand.Research]: async for research_result in research( @@ -1031,12 +1027,11 @@ async def event_generator( send_status_func=partial(send_event, ChatEvent.STATUS), user_name=user_name, location=location, - file_filters=file_filters, query_files=attached_file_context, - tracer=tracer, cancellation_event=cancellation_event, interrupt_queue=child_interrupt_queue, abort_message=ChatEvent.END_EVENT.value, + tracer=tracer, ): if isinstance(research_result, ResearchIteration): if research_result.summarizedResult: diff --git a/src/khoj/routers/helpers.py b/src/khoj/routers/helpers.py index 5a47bfcc..6c3eac0f 100644 --- a/src/khoj/routers/helpers.py +++ b/src/khoj/routers/helpers.py @@ -345,7 +345,6 @@ async def acheck_if_safe_prompt(system_prompt: str, user: KhojUser = None, lax: async def aget_data_sources_and_output_format( query: str, chat_history: list[ChatMessageModel], - is_task: bool, user: KhojUser, query_images: List[str] = None, agent: Agent = None, diff --git a/src/khoj/routers/research.py b/src/khoj/routers/research.py index 86980c08..43abaaf0 100644 --- a/src/khoj/routers/research.py +++ b/src/khoj/routers/research.py @@ -218,12 +218,11 @@ async def research( send_status_func: Optional[Callable] = None, user_name: str = None, location: LocationData = None, - file_filters: List[str] = [], - tracer: dict = {}, query_files: str = None, cancellation_event: Optional[asyncio.Event] = None, interrupt_queue: Optional[asyncio.Queue] = None, abort_message: str = ChatEvent.END_EVENT.value, + tracer: dict = {}, ): max_document_searches = 7 max_online_searches = 3