mirror of
https://github.com/crewAIInc/crewAI.git
synced 2026-01-09 16:18:30 +00:00
children router working. Need to support loops
This commit is contained in:
@@ -96,16 +96,19 @@ class PyvisFlowVisualizer(FlowVisualizer):
|
|||||||
)
|
)
|
||||||
|
|
||||||
# Add edges
|
# Add edges
|
||||||
|
print("self.flow._routers.values()", self.flow._routers)
|
||||||
for method_name in self.flow._listeners:
|
for method_name in self.flow._listeners:
|
||||||
|
print("Listeners for", method_name)
|
||||||
condition_type, trigger_methods = self.flow._listeners[method_name]
|
condition_type, trigger_methods = self.flow._listeners[method_name]
|
||||||
is_and_condition = condition_type == "AND"
|
is_and_condition = condition_type == "AND"
|
||||||
|
|
||||||
for trigger in trigger_methods:
|
for trigger in trigger_methods:
|
||||||
|
print("Trigger", trigger)
|
||||||
if trigger in self.flow._methods:
|
if trigger in self.flow._methods:
|
||||||
is_router_edge = (
|
is_router_edge = any(
|
||||||
trigger in self.flow._routers.values()
|
trigger in paths for paths in self.flow._router_paths.values()
|
||||||
or method_name in self.flow._routers.values()
|
|
||||||
)
|
)
|
||||||
|
print("is_router_edge", is_router_edge)
|
||||||
edge_color = (
|
edge_color = (
|
||||||
self.colors["router_edge"]
|
self.colors["router_edge"]
|
||||||
if is_router_edge
|
if is_router_edge
|
||||||
|
|||||||
Reference in New Issue
Block a user