diff --git a/api/core/workflow/workflow_engine_manager.py b/api/core/workflow/workflow_engine_manager.py
index 99ebf7c72e..5eb92f02ef 100644
--- a/api/core/workflow/workflow_engine_manager.py
+++ b/api/core/workflow/workflow_engine_manager.py
@@ -340,7 +340,7 @@ class WorkflowEngineManager:
                 if predecessor_node.node_run_result else None
             if source_handle:
                 for edge in outgoing_edges:
-                    if edge.get('source_handle') and edge.get('source_handle') == source_handle:
+                    if edge.get('sourceHandle') and edge.get('sourceHandle') == source_handle:
                         outgoing_edge = edge
                         break
             else: