|
|
|
@ -18,6 +18,7 @@ from core.workflow.entities.node_entities import AgentNodeStrategyInit, NodeRunM
|
|
|
|
from core.workflow.entities.variable_pool import VariablePool, VariableValue
|
|
|
|
from core.workflow.entities.variable_pool import VariablePool, VariableValue
|
|
|
|
from core.workflow.graph_engine.condition_handlers.condition_manager import ConditionManager
|
|
|
|
from core.workflow.graph_engine.condition_handlers.condition_manager import ConditionManager
|
|
|
|
from core.workflow.graph_engine.entities.event import (
|
|
|
|
from core.workflow.graph_engine.entities.event import (
|
|
|
|
|
|
|
|
BaseAgentEvent,
|
|
|
|
BaseIterationEvent,
|
|
|
|
BaseIterationEvent,
|
|
|
|
GraphEngineEvent,
|
|
|
|
GraphEngineEvent,
|
|
|
|
GraphRunFailedEvent,
|
|
|
|
GraphRunFailedEvent,
|
|
|
|
@ -501,7 +502,7 @@ class GraphEngine:
|
|
|
|
break
|
|
|
|
break
|
|
|
|
|
|
|
|
|
|
|
|
yield event
|
|
|
|
yield event
|
|
|
|
if event.parallel_id == parallel_id:
|
|
|
|
if not isinstance(event, BaseAgentEvent) and event.parallel_id == parallel_id:
|
|
|
|
if isinstance(event, ParallelBranchRunSucceededEvent):
|
|
|
|
if isinstance(event, ParallelBranchRunSucceededEvent):
|
|
|
|
succeeded_count += 1
|
|
|
|
succeeded_count += 1
|
|
|
|
if succeeded_count == len(futures):
|
|
|
|
if succeeded_count == len(futures):
|
|
|
|
|