Using AsyncPostgresSaver and AsyncPostgresStore - the code compiles, But I do not get an output or response.

[PoojithaGowthaman]

Hi @vbarda, I am adding both short term and long term memory for my agent. The code compiles without errors, but I do not get a response from LLM. Could You please help me understand if my implementation is correct?

`. async def agent(payload: AgentPayload):
# temp place holder value
user_id = "1" + str(payload.session_id)
namespace_for_memory = (user_id, payload.session_id)
config = {"configurable": {"thread_id": payload.session_id, "user_id": user_id}}

    pool_kwargs = {
        "autocommit": True,
        "prepare_threshold": 0,
        "options": "-c search_path=chatbot",
        "row_factory": dict_row,  
    }
    
    async with AsyncConnectionPool(
        conninfo=DB_URI,
        max_size=20,
        kwargs=pool_kwargs,
    ) as pool:
        await pool.open()
        # timeit
        checkpointer = AsyncPostgresSaver(pool)
        store = AsyncPostgresStore(pool)
        await checkpointer.setup()
        await store.setup()

        # Fetch message history from PostgreSQL
        longterm_memory = await store.asearch(namespace_for_memory)
        longterm_memory = []  # Default to empty if retrieval fails

        # Instantiate system_message
        system_message = """
        You are a helpful assistant tasked with performing content creation that cater to users request.
        --------
        """

        if hasattr(payload, "confirm_tool_use") and payload.confirm_tool_use:
            system_message += (
                "\n\n"
                + "Before every tool call, t------"
            )

        # Populate all the tools
        agent = Agenttools(
            config=config,
            checkpointer=checkpointer,
            store=longterm_memory,
            system_message=system_message,
            tools_list=payload.tools_list,
        )

        # Instantiate the agents
        agent.build_graph()

        # Prepare messages
        input_messages = [HumanMessage(content=payload.messages)]

        agent_output = await agent.graph.astream(input_messages, config)

        # Save agent_output to PostgreSQL
        new_version = "1.0"  
        await checkpointer.put(
            namespace_for_memory, payload.session_id, agent_output, new_version
        )
        await longterm_memory.put(
            namespace_for_memory, payload.session_id, agent_output, new_version
        )
        
        await checkpointer.close()
        await store.close()
        await pool.close()

        return agent_output

`

the output of the long term memory is returned {'3', 'v'} since I passed the "row_factory": dict_row, in kwargs. I was able to create the checkpointer successfully, the problem is when is when I add the long term memory.