Function _make_nodes_sequential

src/google/adk/cli/agent_test_runner.py:231–250

(obj, visited=None)

def _make_nodes_sequential(obj, visited=None):
  if visited is None:
    visited = set()

  if id(obj) in visited:
    return
  visited.add(id(obj))

  from google.adk.workflow._parallel_worker import _ParallelWorker
  from google.adk.workflow._workflow import Workflow

  if isinstance(obj, Workflow):
    obj.max_concurrency = 1
    if obj.graph and obj.graph.nodes:
      for node in obj.graph.nodes:
        _make_nodes_sequential(node, visited)
  elif isinstance(obj, _ParallelWorker):
    obj.max_concurrency = 1
    if hasattr(obj, "_node"):
      _make_nodes_sequential(obj._node, visited)


def _get_all_agent_names(obj, visited=None):