I used the code in the LangChain official website tutorial, but got an error

[AChineseBoy]

Checked other resources

• I added a very descriptive title to this question.
• I searched the LangChain documentation with the integrated search.
• I used the GitHub search to find a similar question and didn't find it.

Commit to Help

• I commit to help with one of those options 👆

Example Code

async for event in agent_executor.astream_events(
    {"messages": [HumanMessage(content="whats the weather in sf?")]}, version="v1"
):
    kind = event["event"]
    if kind == "on_chain_start":
        if (
            event["name"] == "Agent"
        ):  # Was assigned when creating the agent with `.with_config({"run_name": "Agent"})`
            print(
                f"Starting agent: {event['name']} with input: {event['data'].get('input')}"
            )
    elif kind == "on_chain_end":
        if (
            event["name"] == "Agent"
        ):  # Was assigned when creating the agent with `.with_config({"run_name": "Agent"})`
            print()
            print("--")
            print(
                f"Done agent: {event['name']} with output: {event['data'].get('output')['output']}"
            )
    if kind == "on_chat_model_stream":
        content = event["data"]["chunk"].content
        if content:
            # Empty content in the context of OpenAI means
            # that the model is asking for a tool to be invoked.
            # So we only print non-empty content
            print(content, end="|")
    elif kind == "on_tool_start":
        print("--")
        print(
            f"Starting tool: {event['name']} with inputs: {event['data'].get('input')}"
        )
    elif kind == "on_tool_end":
        print(f"Done tool: {event['name']}")
        print(f"Tool output was: {event['data'].get('output')}")
        print("--")

Description

I used the code in the LangChain official website tutorial, but got an error。

async for event in agent_executor.astream_events( 

SyntaxError: 'async for' outside async function

System Info

Mac
python3.11.8

[feijoes]

@AChineseBoy The async for loop need to be inside a async function

for example

async def demo():
      async for event in agent_executor.astream_events(
          {"messages": [HumanMessage(content="whats the weather in sf?")]}, version="v1"
      ):
      ....

[ENUMERA8OR]

You need to be careful using code from the langchain website. Usually when you google search it it leads you to the old versiondocs website. Make sure to check the version number with the version you are using to avoid compatibility issues beforehand.