Run background

async def run_agent_in_background(
    query: str, app_data: AppData
) -> BaseAgentResponse | DataAgentResponse:
    """Background task to process the query using the `langchain` agent.

    Args:
        query (str): User query to process.
        app_data (AppData): Objects needed to run the agent successfully.

    Returns:
        BaseAgentResponse | DataAgentResponse: Response to the query.
    """

    try:
        openbb_pat_mongo = db.tokens.find_one({}, {"_id": 0, "openbb": 1}).get("openbb")
        openbb_pat = (
            str(openbb_pat_mongo) if openbb_pat_mongo is not None else openbb_pat_mongo
        )  # Retrieve OpenBB PAT from database

        # Run agent. Best responses but high quality LLMs needed (e.g., Claude Instant or GPT-3.5)
        agent_res = await app_data.agent_executor.ainvoke(
            {"input": query},
        )

        # If last step is OpenBB, run code
        if (
            len(agent_res["intermediate_steps"]) > 0
            and agent_res["intermediate_steps"][-1][0].tool == "OpenBB"
        ):
            output_str = run_repl_over_openbb(
                openbb_chat_output=agent_res["intermediate_steps"][-1][1],
                python_repl_utility=app_data.python_repl_utility,
                openbb_pat=openbb_pat,
            )
            if "```json" in output_str:
                try:
                    result_data_str = output_str.split("```json")[1].split("```")[0].strip()
                    result_data = json.loads(result_data_str)
                    body_data_str = output_str.split("```json")[0].strip()

                    return DataAgentResponse(
                        type="data", result_data=result_data, body=body_data_str
                    )
                except Exception as e:
                    return BaseAgentResponse(type="data", body=output_str)
        else:
            output_str = add_context_to_output(
                output=agent_res["output"],
                tools_executed=[step[0].tool for step in agent_res["intermediate_steps"]],
            )
        return BaseAgentResponse(type="data", body=output_str)
    except Exception as e:
        print("Overall exception happened: " + str(e))
        return BaseAgentResponse(type="error", body="Sorry, something went wrong!")