diff --git a/libs/langgraph/tests/test_large_cases.py b/libs/langgraph/tests/test_large_cases.py index 57c9b4071..a9d54b98d 100644 --- a/libs/langgraph/tests/test_large_cases.py +++ b/libs/langgraph/tests/test_large_cases.py @@ -2483,7 +2483,7 @@ def test_prebuilt_tool_chat(snapshot: SnapshotAssertion) -> None: { "langgraph_step": 1, "langgraph_node": "agent", - "langgraph_triggers": ["start:agent"], + "langgraph_triggers": ("start:agent",), "langgraph_path": (PULL, "agent"), "langgraph_checkpoint_ns": AnyStr("agent:"), "checkpoint_ns": AnyStr("agent:"), @@ -2500,7 +2500,7 @@ def test_prebuilt_tool_chat(snapshot: SnapshotAssertion) -> None: { "langgraph_step": 2, "langgraph_node": "tools", - "langgraph_triggers": ["branch:to:tools"], + "langgraph_triggers": ("branch:to:tools",), "langgraph_path": (PULL, "tools"), "langgraph_checkpoint_ns": AnyStr("tools:"), }, @@ -2542,7 +2542,7 @@ def test_prebuilt_tool_chat(snapshot: SnapshotAssertion) -> None: { "langgraph_step": 3, "langgraph_node": "agent", - "langgraph_triggers": ["tools"], + "langgraph_triggers": ("tools",), "langgraph_path": (PULL, "agent"), "langgraph_checkpoint_ns": AnyStr("agent:"), "checkpoint_ns": AnyStr("agent:"), @@ -2559,7 +2559,7 @@ def test_prebuilt_tool_chat(snapshot: SnapshotAssertion) -> None: { "langgraph_step": 4, "langgraph_node": "tools", - "langgraph_triggers": ["branch:to:tools"], + "langgraph_triggers": ("branch:to:tools",), "langgraph_path": (PULL, "tools"), "langgraph_checkpoint_ns": AnyStr("tools:"), }, @@ -2573,7 +2573,7 @@ def test_prebuilt_tool_chat(snapshot: SnapshotAssertion) -> None: { "langgraph_step": 4, "langgraph_node": "tools", - "langgraph_triggers": ["branch:to:tools"], + "langgraph_triggers": ("branch:to:tools",), "langgraph_path": (PULL, "tools"), "langgraph_checkpoint_ns": AnyStr("tools:"), }, @@ -2585,7 +2585,7 @@ def test_prebuilt_tool_chat(snapshot: SnapshotAssertion) -> None: { "langgraph_step": 5, "langgraph_node": "agent", - "langgraph_triggers": ["tools"], + "langgraph_triggers": ("tools",), "langgraph_path": (PULL, "agent"), "langgraph_checkpoint_ns": AnyStr("agent:"), "checkpoint_ns": AnyStr("agent:"), @@ -5501,7 +5501,7 @@ def test_in_one_fan_out_out_one_graph_state() -> None: "id": AnyStr(), "name": "rewrite_query", "input": {"query": "what is weather in sf", "docs": []}, - "triggers": ["start:rewrite_query"], + "triggers": ("start:rewrite_query",), }, }, ), @@ -5532,7 +5532,7 @@ def test_in_one_fan_out_out_one_graph_state() -> None: "id": AnyStr(), "name": "retriever_one", "input": {"query": "query: what is weather in sf", "docs": []}, - "triggers": ["rewrite_query"], + "triggers": ("rewrite_query",), }, }, ), @@ -5546,7 +5546,7 @@ def test_in_one_fan_out_out_one_graph_state() -> None: "id": AnyStr(), "name": "retriever_two", "input": {"query": "query: what is weather in sf", "docs": []}, - "triggers": ["rewrite_query"], + "triggers": ("rewrite_query",), }, }, ), @@ -5608,7 +5608,7 @@ def test_in_one_fan_out_out_one_graph_state() -> None: "query": "query: what is weather in sf", "docs": ["doc1", "doc2", "doc3", "doc4"], }, - "triggers": ["retriever_one", "retriever_two"], + "triggers": ("retriever_one",), }, }, ), @@ -6634,7 +6634,7 @@ def test_branch_then( "id": AnyStr(), "name": "prepare", "input": {"my_key": "value", "market": "DE"}, - "triggers": ["start:prepare"], + "triggers": ("start:prepare",), }, }, { @@ -6706,7 +6706,7 @@ def test_branch_then( "id": AnyStr(), "name": "tool_two_slow", "input": {"my_key": "value prepared", "market": "DE"}, - "triggers": ["branch:to:tool_two_slow"], + "triggers": ("branch:to:tool_two_slow",), }, }, { @@ -6773,7 +6773,7 @@ def test_branch_then( "id": AnyStr(), "name": "finish", "input": {"my_key": "value prepared slow", "market": "DE"}, - "triggers": ["branch:prepare:condition::then"], + "triggers": ("branch:prepare:condition::then",), }, }, { diff --git a/libs/langgraph/tests/test_large_cases_async.py b/libs/langgraph/tests/test_large_cases_async.py index 95fcb9646..f7f11da0c 100644 --- a/libs/langgraph/tests/test_large_cases_async.py +++ b/libs/langgraph/tests/test_large_cases_async.py @@ -2300,7 +2300,7 @@ async def test_prebuilt_tool_chat() -> None: { "langgraph_step": 1, "langgraph_node": "agent", - "langgraph_triggers": ["start:agent"], + "langgraph_triggers": ("start:agent",), "langgraph_path": ("__pregel_pull", "agent"), "langgraph_checkpoint_ns": AnyStr("agent:"), "checkpoint_ns": AnyStr("agent:"), @@ -2317,7 +2317,7 @@ async def test_prebuilt_tool_chat() -> None: { "langgraph_step": 2, "langgraph_node": "tools", - "langgraph_triggers": ["branch:to:tools"], + "langgraph_triggers": ("branch:to:tools",), "langgraph_path": ("__pregel_pull", "tools"), "langgraph_checkpoint_ns": AnyStr("tools:"), }, @@ -2359,7 +2359,7 @@ async def test_prebuilt_tool_chat() -> None: { "langgraph_step": 3, "langgraph_node": "agent", - "langgraph_triggers": ["tools"], + "langgraph_triggers": ("tools",), "langgraph_path": ("__pregel_pull", "agent"), "langgraph_checkpoint_ns": AnyStr("agent:"), "checkpoint_ns": AnyStr("agent:"), @@ -2376,7 +2376,7 @@ async def test_prebuilt_tool_chat() -> None: { "langgraph_step": 4, "langgraph_node": "tools", - "langgraph_triggers": ["branch:to:tools"], + "langgraph_triggers": ("branch:to:tools",), "langgraph_path": ("__pregel_pull", "tools"), "langgraph_checkpoint_ns": AnyStr("tools:"), }, @@ -2390,7 +2390,7 @@ async def test_prebuilt_tool_chat() -> None: { "langgraph_step": 4, "langgraph_node": "tools", - "langgraph_triggers": ["branch:to:tools"], + "langgraph_triggers": ("branch:to:tools",), "langgraph_path": ("__pregel_pull", "tools"), "langgraph_checkpoint_ns": AnyStr("tools:"), }, @@ -2402,7 +2402,7 @@ async def test_prebuilt_tool_chat() -> None: { "langgraph_step": 5, "langgraph_node": "agent", - "langgraph_triggers": ["tools"], + "langgraph_triggers": ("tools",), "langgraph_path": ("__pregel_pull", "agent"), "langgraph_checkpoint_ns": AnyStr("agent:"), "checkpoint_ns": AnyStr("agent:"), @@ -3883,7 +3883,7 @@ async def test_in_one_fan_out_out_one_graph_state() -> None: "id": AnyStr(), "name": "rewrite_query", "input": {"query": "what is weather in sf", "docs": []}, - "triggers": ["start:rewrite_query"], + "triggers": ("start:rewrite_query",), }, }, ), @@ -3914,7 +3914,7 @@ async def test_in_one_fan_out_out_one_graph_state() -> None: "id": AnyStr(), "name": "retriever_one", "input": {"query": "query: what is weather in sf", "docs": []}, - "triggers": ["rewrite_query"], + "triggers": ("rewrite_query",), }, }, ), @@ -3928,7 +3928,7 @@ async def test_in_one_fan_out_out_one_graph_state() -> None: "id": AnyStr(), "name": "retriever_two", "input": {"query": "query: what is weather in sf", "docs": []}, - "triggers": ["rewrite_query"], + "triggers": ("rewrite_query",), }, }, ), @@ -3990,7 +3990,7 @@ async def test_in_one_fan_out_out_one_graph_state() -> None: "query": "query: what is weather in sf", "docs": ["doc1", "doc2", "doc3", "doc4"], }, - "triggers": ["retriever_one", "retriever_two"], + "triggers": ("retriever_one",), }, }, ), @@ -4465,7 +4465,7 @@ async def test_branch_then(checkpointer_name: str) -> None: "id": AnyStr(), "name": "prepare", "input": {"my_key": "value", "market": "DE"}, - "triggers": ["start:prepare"], + "triggers": ("start:prepare",), }, }, { @@ -4537,7 +4537,7 @@ async def test_branch_then(checkpointer_name: str) -> None: "id": AnyStr(), "name": "tool_two_slow", "input": {"my_key": "value prepared", "market": "DE"}, - "triggers": ["branch:to:tool_two_slow"], + "triggers": ("branch:to:tool_two_slow",), }, }, { @@ -4609,7 +4609,7 @@ async def test_branch_then(checkpointer_name: str) -> None: "id": AnyStr(), "name": "finish", "input": {"my_key": "value prepared slow", "market": "DE"}, - "triggers": ["branch:prepare:condition::then"], + "triggers": ("branch:prepare:condition::then",), }, }, { @@ -4778,7 +4778,7 @@ async def test_branch_then(checkpointer_name: str) -> None: "id": AnyStr(), "name": "prepare", "input": {"my_key": "value", "market": "DE"}, - "triggers": ["start:prepare"], + "triggers": ("start:prepare",), }, }, { diff --git a/libs/langgraph/tests/test_pregel.py b/libs/langgraph/tests/test_pregel.py index ccd899ce9..f4af98b52 100644 --- a/libs/langgraph/tests/test_pregel.py +++ b/libs/langgraph/tests/test_pregel.py @@ -817,7 +817,7 @@ def test_invoke_two_processes_in_dict_out(mocker: MockerFixture) -> None: "id": AnyStr(), "name": "one", "input": 2, - "triggers": ["input"], + "triggers": ("input",), }, }, { @@ -828,7 +828,7 @@ def test_invoke_two_processes_in_dict_out(mocker: MockerFixture) -> None: "id": AnyStr(), "name": "two", "input": [12], - "triggers": ["inbox"], + "triggers": ("inbox",), }, }, { @@ -863,7 +863,7 @@ def test_invoke_two_processes_in_dict_out(mocker: MockerFixture) -> None: "id": AnyStr(), "name": "two", "input": [3], - "triggers": ["inbox"], + "triggers": ("inbox",), }, }, { @@ -5969,9 +5969,7 @@ def test_falsy_return_from_task( "a": 5, }, "name": "graph", - "triggers": [ - "__start__", - ], + "triggers": ("__start__",), }, "step": 0, "timestamp": AnyStr(), @@ -5985,9 +5983,7 @@ def test_falsy_return_from_task( {}, ), "name": "falsy_task", - "triggers": [ - "__pregel_push", - ], + "triggers": ("__pregel_push",), }, "step": 0, "timestamp": AnyStr(), @@ -6094,9 +6090,7 @@ def test_falsy_return_from_task( "a": 5, }, "name": "graph", - "triggers": [ - "__start__", - ], + "triggers": ("__start__",), }, "step": 0, "timestamp": AnyStr(), @@ -6110,9 +6104,7 @@ def test_falsy_return_from_task( {}, ), "name": "falsy_task", - "triggers": [ - "__pregel_push", - ], + "triggers": ("__pregel_push",), }, "step": 0, "timestamp": AnyStr(), @@ -6923,7 +6915,7 @@ def test_tags_stream_mode_messages() -> None: { "langgraph_step": 1, "langgraph_node": "call_model", - "langgraph_triggers": ["start:call_model"], + "langgraph_triggers": ("start:call_model",), "langgraph_path": ("__pregel_pull", "call_model"), "langgraph_checkpoint_ns": AnyStr("call_model:"), "checkpoint_ns": AnyStr("call_model:"), diff --git a/libs/langgraph/tests/test_pregel_async.py b/libs/langgraph/tests/test_pregel_async.py index a42a84a28..f1bb4d8ab 100644 --- a/libs/langgraph/tests/test_pregel_async.py +++ b/libs/langgraph/tests/test_pregel_async.py @@ -1672,7 +1672,7 @@ async def test_invoke_two_processes_in_dict_out(mocker: MockerFixture) -> None: "id": AnyStr(), "name": "one", "input": 2, - "triggers": ["input"], + "triggers": ("input",), }, }, { @@ -1683,7 +1683,7 @@ async def test_invoke_two_processes_in_dict_out(mocker: MockerFixture) -> None: "id": AnyStr(), "name": "two", "input": [12], - "triggers": ["inbox"], + "triggers": ("inbox",), }, }, { @@ -1718,7 +1718,7 @@ async def test_invoke_two_processes_in_dict_out(mocker: MockerFixture) -> None: "id": AnyStr(), "name": "two", "input": [3], - "triggers": ["inbox"], + "triggers": ("inbox",), }, }, { @@ -7571,7 +7571,7 @@ async def test_tags_stream_mode_messages() -> None: { "langgraph_step": 1, "langgraph_node": "call_model", - "langgraph_triggers": ["start:call_model"], + "langgraph_triggers": ("start:call_model",), "langgraph_path": ("__pregel_pull", "call_model"), "langgraph_checkpoint_ns": AnyStr("call_model:"), "checkpoint_ns": AnyStr("call_model:"),