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 07:59:25 UTC
[incubator-heron] branch nicknezis/tracker-packing-plan-fix created (now 2964278)
This is an automated email from the ASF dual-hosted git repository.
nicknezis pushed a change to branch nicknezis/tracker-packing-plan-fix
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git.
at 2964278 Added missing packing plan handler
This branch includes the following new commits:
new 2964278 Added missing packing plan handler
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[incubator-heron] 01/01: Added missing packing plan handler
Posted by 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(