art-dag/celery
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compute step_count in recipe service

Browse Source 
Check multiple locations for nodes (nodes, dag.nodes, pipeline, steps)
and compute step_count for display in recipe list.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
gilesb
2026-01-11 22:09:34 +00:00
parent 145c69f21b
commit 9a8e26e79c
1 changed files with 17 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
app/services/recipe_service.py
View File

@@ -42,6 +42,23 @@ class RecipeService:
if ipfs_cid:
recipe_data["ipfs_cid"] = ipfs_cid
# Compute step_count from nodes
nodes = recipe_data.get("nodes", [])
if not nodes:
dag = recipe_data.get("dag", {})
nodes = dag.get("nodes", []) if isinstance(dag, dict) else []
if not nodes:
nodes = recipe_data.get("pipeline", [])
if not nodes:
nodes = recipe_data.get("steps", [])
if isinstance(nodes, list):
recipe_data["step_count"] = len(nodes)
elif isinstance(nodes, dict):
recipe_data["step_count"] = len(nodes)
else:
recipe_data["step_count"] = 0
return recipe_data
async def list_recipes(self, actor_id: str = None, offset: int = 0, limit: int = 20) -> list: