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

Reply via email to