@@ -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