diff --git a/backend/app/api/routes/utils.py b/backend/app/api/routes/utils.py index 5a9a562..fa2ba54 100644 --- a/backend/app/api/routes/utils.py +++ b/backend/app/api/routes/utils.py @@ -69,7 +69,9 @@ async def health(request: Request, response: Response) -> dict[str, Any]: redis_info["rtt_ms"] = round((time.perf_counter() - start) * 1000, 1) if not connected: problems.append("redis unreachable") - engine["flows"] = len(getattr(controller, "loaded", {}) or {}) + # `loaded` is keyed by node id, so its length is a node count. + loaded = getattr(controller, "loaded", {}) or {} + engine["flows"] = len({entry.flow for entry in loaded.values()}) engine["nodes"] = len( getattr(getattr(controller, "pipeline", None), "nodes", []) or [] )