This is an automated email from the ASF dual-hosted git repository.
linxinyuan pushed a commit to branch xinyuan-cm-for-loop-mat-dcm
in repository https://gitbox.apache.org/repos/asf/texera.git
The following commit(s) were added to refs/heads/xinyuan-cm-for-loop-mat-dcm by
this push:
new b826718f8b update
b826718f8b is described below
commit b826718f8bf7cabc2b6406a298395ea008a2165f
Author: Xinyuan Lin <[email protected]>
AuthorDate: Fri Feb 6 19:18:34 2026 -0800
update
---
.../architecture/scheduling/WorkflowExecutionCoordinator.scala | 10 ----------
1 file changed, 10 deletions(-)
diff --git
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/WorkflowExecutionCoordinator.scala
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/WorkflowExecutionCoordinator.scala
index 8939c2f4f3..d70a2345a7 100644
---
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/WorkflowExecutionCoordinator.scala
+++
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/WorkflowExecutionCoordinator.scala
@@ -103,16 +103,6 @@ class WorkflowExecutionCoordinator(
.unit
}
- /**
- * Mark the given operator as iteration-completed.
- *
- * This is a UI/observability state only; it doesn't change the
worker-level state machine.
- */
- def markOperatorIterationCompleted(operatorExecution: OperatorExecution):
Unit = {
- // No-op placeholder: operator aggregated state is computed from
WorkerState.
- // IterationCompleted is currently an observability/UI state driven by
region phase events.
- ()
- }
/**
* If all operators in the region have reached ITERATION_COMPLETED (or
COMPLETED), mark the region as