@@ -281,7 +281,7 @@ def _find_newly_ready_nodes(self) -> list["GraphNode"]:
281281                newly_ready .append (node )
282282        return  newly_ready 
283283
284-     def  _is_node_ready_with_conditions (self , node : " GraphNode" ->  bool :
284+     def  _is_node_ready_with_conditions (self , node : GraphNode ) ->  bool :
285285        """Check if a node is ready considering conditional edges.""" 
286286        # Get incoming edges to this node 
287287        incoming_edges  =  [edge  for  edge  in  self .edges  if  edge .to_node  ==  node ]
@@ -303,7 +303,7 @@ def _is_node_ready_with_conditions(self, node: "GraphNode") -> bool:
303303                    )
304304        return  False 
305305
306-     async  def  _execute_node (self , node : " GraphNode" ->  None :
306+     async  def  _execute_node (self , node : GraphNode ) ->  None :
307307        """Execute a single node with error handling.""" 
308308        node .status  =  Status .EXECUTING 
309309        logger .debug ("node_id=<%s> | executing node" , node .node_id )
@@ -401,7 +401,7 @@ def _accumulate_metrics(self, node_result: NodeResult) -> None:
401401        self .state .accumulated_metrics ["latencyMs" ] +=  node_result .accumulated_metrics .get ("latencyMs" , 0 )
402402        self .state .execution_count  +=  node_result .execution_count 
403403
404-     def  _build_node_input (self , node : " GraphNode" ->  str :
404+     def  _build_node_input (self , node : GraphNode ) ->  str :
405405        """Build input text for a node based on dependency outputs.""" 
406406        # Get satisfied dependencies 
407407        dependency_results  =  {}
0 commit comments