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

linxinyuan pushed a commit to branch xinyuan-loop-feb
in repository https://gitbox.apache.org/repos/asf/texera.git


The following commit(s) were added to refs/heads/xinyuan-loop-feb by this push:
     new b18d9dbc52 update
b18d9dbc52 is described below

commit b18d9dbc523378052189c7b187a310c05329ef35
Author: Xinyuan Lin <[email protected]>
AuthorDate: Wed Mar 4 01:37:39 2026 -0800

    update
---
 amber/src/main/python/core/models/operator.py                         | 4 ++--
 .../scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala   | 4 ++++
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/amber/src/main/python/core/models/operator.py 
b/amber/src/main/python/core/models/operator.py
index e05bd45b6c..7532fae1bd 100644
--- a/amber/src/main/python/core/models/operator.py
+++ b/amber/src/main/python/core/models/operator.py
@@ -311,9 +311,9 @@ class LoopEndOperator(TableOperator):
     def open(self) -> None:
         pass
 
-    @overrides.final
+    @abstractmethod
     def process_table(self, table: Table, port: int) -> 
Iterator[Optional[TableLike]]:
-        yield table
+        yield
 
     def close(self) -> None:
         pass
diff --git 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala
 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala
index 719b14afe2..d5aa4a0a72 100644
--- 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala
+++ 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/loop/LoopEndOpDesc.scala
@@ -79,6 +79,10 @@ class LoopEndOpDesc extends LogicalOp {
        |      $update
        |      print(i)
        |      return state
+       |
+       |    @overrides
+       |    def process_table(self, table: Table, port: int) -> 
Iterator[Optional[TableLike]]:
+       |        yield table
        |""".stripMargin
   }
 }

Reply via email to