[incubator-heron] 01/01: Added missing packing plan handler

[ni...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

nicknezis pushed a commit to branch nicknezis/tracker-packing-plan-fix
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git

commit 2964278dffe4b4b06e2159fbd4d0bca96f308049
Author: Nicholas Nezis <ni...@gmail.com>
AuthorDate: Mon Feb 28 02:59:06 2022 -0500

    Added missing packing plan handler
---
 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(