checkpointer = AsyncMongoDBSaver(
            client=async_mongodb_client, db_name=settings.MEMORY_DB_NAME
        )


        # Create the state graph
        state_graph: StateGraph = state_graph()

        # Compile the state graph with the provided checkpointing mechanism
        compiled_state_graph = state_graph.compile(checkpointer=checkpointer)

        # Define configuration with thread ID and assistant ID
        config: RunnableConfig = {
            "configurable": {
                "thread_id": thread_id,
                "assistant_id": assistant_id,
                "user_id": user_id,
            }
        }

        messages = [human_message]

        # Invoke the compiled state graph with user input
        message_data = await compiled_state_graph.ainvoke(
            input={"messages": messages},
            config=config,
            stream_mode="values",
            debug=False,
        )