Add successors to VertexBuildResponse and return only first layer
This commit is contained in:
parent
ac9849013d
commit
5e30aac399
1 changed files with 4 additions and 3 deletions
|
|
@ -85,7 +85,7 @@ async def try_running_celery_task(vertex, user_id):
|
|||
@router.get("/build/{flow_id}/vertices", response_model=VerticesOrderResponse)
|
||||
async def get_vertices(
|
||||
flow_id: str,
|
||||
component_id: Optional[str] = None,
|
||||
stop_vertex_id: Optional[str] = None,
|
||||
chat_service: "ChatService" = Depends(get_chat_service),
|
||||
session=Depends(get_session),
|
||||
):
|
||||
|
|
@ -96,9 +96,9 @@ async def get_vertices(
|
|||
if cache := chat_service.get_cache(flow_id):
|
||||
graph: Graph = cache.get("result")
|
||||
graph = build_and_cache_graph(flow_id, session, chat_service, graph)
|
||||
if component_id:
|
||||
if stop_vertex_id:
|
||||
try:
|
||||
vertices = graph.sort_vertices(component_id)
|
||||
vertices = graph.sort_vertices(stop_vertex_id)
|
||||
except Exception as exc:
|
||||
logger.error(exc)
|
||||
vertices = graph.sort_vertices()
|
||||
|
|
@ -189,6 +189,7 @@ async def build_vertex(
|
|||
vertex.add_build_time(timedelta)
|
||||
|
||||
return VertexBuildResponse(
|
||||
successors=vertex.successors_ids,
|
||||
valid=valid,
|
||||
params=params,
|
||||
id=vertex.id,
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue