@@ -281,7 +281,7 @@ def _find_newly_ready_nodes(self) -> list["GraphNode"]:
281
281
newly_ready .append (node )
282
282
return newly_ready
283
283
284
- def _is_node_ready_with_conditions (self , node : " GraphNode" ) -> bool :
284
+ def _is_node_ready_with_conditions (self , node : GraphNode ) -> bool :
285
285
"""Check if a node is ready considering conditional edges."""
286
286
# Get incoming edges to this node
287
287
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:
303
303
)
304
304
return False
305
305
306
- async def _execute_node (self , node : " GraphNode" ) -> None :
306
+ async def _execute_node (self , node : GraphNode ) -> None :
307
307
"""Execute a single node with error handling."""
308
308
node .status = Status .EXECUTING
309
309
logger .debug ("node_id=<%s> | executing node" , node .node_id )
@@ -401,7 +401,7 @@ def _accumulate_metrics(self, node_result: NodeResult) -> None:
401
401
self .state .accumulated_metrics ["latencyMs" ] += node_result .accumulated_metrics .get ("latencyMs" , 0 )
402
402
self .state .execution_count += node_result .execution_count
403
403
404
- def _build_node_input (self , node : " GraphNode" ) -> str :
404
+ def _build_node_input (self , node : GraphNode ) -> str :
405
405
"""Build input text for a node based on dependency outputs."""
406
406
# Get satisfied dependencies
407
407
dependency_results = {}
0 commit comments