You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@heron.apache.org by ni...@apache.org on 2022/02/28 08:45:19 UTC
[incubator-heron] branch master updated: Added missing packing plan handler in heron-tracker (#3783)
This is an automated email from the ASF dual-hosted git repository.
nicknezis pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
The following commit(s) were added to refs/heads/master by this push:
new 1a54477 Added missing packing plan handler in heron-tracker (#3783)
1a54477 is described below
commit 1a544770a66531e0b6f984426f1f74da03c5ee3a
Author: Nicholas Nezis <ni...@gmail.com>
AuthorDate: Mon Feb 28 03:45:09 2022 -0500
Added missing packing plan handler in heron-tracker (#3783)
---
heron/tools/tracker/src/python/routers/topologies.py | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/heron/tools/tracker/src/python/routers/topologies.py b/heron/tools/tracker/src/python/routers/topologies.py
index c96bbdb..e1d8801 100644
--- a/heron/tools/tracker/src/python/routers/topologies.py
+++ b/heron/tools/tracker/src/python/routers/topologies.py
@@ -33,6 +33,7 @@ from heron.tools.tracker.src.python.topology import (
TopologyInfoExecutionState,
TopologyInfoLogicalPlan,
TopologyInfoMetadata,
+ TopologyInfoPackingPlan,
TopologyInfoPhysicalPlan,
TopologyInfoSchedulerLocation,
)
@@ -114,6 +115,15 @@ async def get_topology_config(
topology_info = topology.info
return topology_info.physical_plan.config
+@router.get("/packingplan", response_model=TopologyInfoPackingPlan)
+async def get_topology_packing_plan(
+ cluster: str,
+ environ: str,
+ topology: str,
+ role: Optional[str] = Query(None, deprecated=True),
+):
+ topology = state.tracker.get_topology(cluster, role, environ, topology)
+ return topology.info.packing_plan
@router.get("/physicalplan", response_model=TopologyInfoPhysicalPlan)
async def get_topology_physical_plan(