From b7f16311b4e4e7789e27521fc832d81ef3785bf3 Mon Sep 17 00:00:00 2001 From: ogabrielluiz Date: Thu, 25 Jun 2026 15:24:58 -0300 Subject: [PATCH] test(loop): accept executor kwargs in subgraph async_start mock The loop body now runs its subgraph through get_default_coordinator().stream, so InProcessExecutor calls async_start with inputs/max_iterations/config/ reset_output_values/fallback_to_env_vars alongside event_manager. The mock only accepted event_manager and raised TypeError on the extra kwargs. Widen it to **_kwargs while still capturing event_manager for the assertion. --- src/backend/tests/unit/components/flow_controls/test_loop.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/backend/tests/unit/components/flow_controls/test_loop.py b/src/backend/tests/unit/components/flow_controls/test_loop.py index 871fa30017..451d29acb5 100644 --- a/src/backend/tests/unit/components/flow_controls/test_loop.py +++ b/src/backend/tests/unit/components/flow_controls/test_loop.py @@ -389,7 +389,7 @@ class TestLoopComponentSubgraphExecution: event_manager_received = [] # Create an async generator that yields mock results - async def mock_async_start(event_manager=None): + async def mock_async_start(event_manager=None, **_kwargs): event_manager_received.append(event_manager) yield MagicMock(valid=True, result_dict={"outputs": {}})