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
}
}