@@ -615,7 +615,7 @@ def from_yaml(
615615 all_routers .update (yaml_routers )
616616
617617 # Process AriumNodes (nested Arium workflows)
618- arium_nodes_config = arium_config .get ('arium_nodes ' , [])
618+ arium_nodes_config = arium_config .get ('ariums ' , [])
619619 arium_nodes_dict = {}
620620
621621 for arium_node_config in arium_nodes_config :
@@ -644,10 +644,10 @@ def from_yaml(
644644 'agents' : arium_node_config .get ('agents' , []),
645645 'tools' : arium_node_config .get ('tools' , []),
646646 'routers' : arium_node_config .get ('routers' , []),
647- 'arium_nodes ' : arium_node_config .get (
648- 'arium_nodes ' , []
647+ 'ariums ' : arium_node_config .get (
648+ 'ariums ' , []
649649 ), # Support nesting!
650- 'foreach_nodes ' : arium_node_config .get ('foreach_nodes ' , []),
650+ 'iterators ' : arium_node_config .get ('iterators ' , []),
651651 'workflow' : arium_node_config ['workflow' ],
652652 }
653653 }
@@ -672,7 +672,7 @@ def from_yaml(
672672 # Don't add to builder yet - will add during workflow processing if actually used
673673
674674 # Process ForEachNodes (store configs, resolve later)
675- foreach_nodes_config = arium_config .get ('foreach_nodes ' , [])
675+ foreach_nodes_config = arium_config .get ('iterators ' , [])
676676 foreach_nodes_dict = {}
677677
678678 for foreach_config in foreach_nodes_config :
0 commit comments