From 64e4d44851db87cbe1f92104c9b6c8ca2dc945ac Mon Sep 17 00:00:00 2001
From: Yicong Huang <17627829+Yicong-Huang@users.noreply.github.com>
Date: Fri, 20 Dec 2024 07:52:43 -0800
Subject: [PATCH] remove unused

---
 .../scala/edu/uci/ics/amber/core/workflow/PhysicalPlan.scala  | 4 ----
 1 file changed, 4 deletions(-)

diff --git a/core/workflow-core/src/main/scala/edu/uci/ics/amber/core/workflow/PhysicalPlan.scala b/core/workflow-core/src/main/scala/edu/uci/ics/amber/core/workflow/PhysicalPlan.scala
index 95681eb7711..ce8070a1aa7 100644
--- a/core/workflow-core/src/main/scala/edu/uci/ics/amber/core/workflow/PhysicalPlan.scala
+++ b/core/workflow-core/src/main/scala/edu/uci/ics/amber/core/workflow/PhysicalPlan.scala
@@ -126,10 +126,6 @@ case class PhysicalPlan(
 
   }
 
-  def getTerminalPhysicalOpIds(): Set[PhysicalOpIdentity] = {
-    operators.filter(op => dag.outDegreeOf(op.id) == 0).map(_.id)
-  }
-
   @JsonIgnore
   def getOutputPartitionInfo(
       link: PhysicalLink,