(texera) branch xinyuan-scheduler-jump updated: refactor(amber): use Schedule.copy in jumpToRegionContainingOperator

[linxinyuan]

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

aglinxinyuan pushed a commit to branch xinyuan-scheduler-jump
in repository https://gitbox.apache.org/repos/asf/texera.git


The following commit(s) were added to refs/heads/xinyuan-scheduler-jump by this 
push:
     new 837323a332 refactor(amber): use Schedule.copy in 
jumpToRegionContainingOperator
837323a332 is described below

commit 837323a3327ffef9e62ab0ce78e7714de6fed985
Author: Xinyuan Lin <xinyu...@uci.edu>
AuthorDate: Fri May 1 16:10:31 2026 -0700

    refactor(amber): use Schedule.copy in jumpToRegionContainingOperator
    
    Reconstruct via the case class's auto-generated `copy(...)` instead of
    the full constructor call, passing `initialLevelIndex =
    schedule.currentLevelIndex` to preserve the iteration cursor across the
    rewrite.
    
    Co-Authored-By: Claude Opus 4.7 (1M context) <nore...@anthropic.com>
---
 .../architecture/scheduling/WorkflowExecutionCoordinator.scala       | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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 c9e3c6cb7e..5d8c2e46ba 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
@@ -153,7 +153,10 @@ class WorkflowExecutionCoordinator(
       val rewrittenLevels =
         schedule.effectiveExecutionLevels.take(schedule.currentLevelIndex) ++
           schedule.baseLevels.drop(levelIndex)
-      schedule = Schedule(schedule.levelSets, rewrittenLevels, 
schedule.currentLevelIndex)
+      schedule = schedule.copy(
+        executionLevels = rewrittenLevels,
+        initialLevelIndex = schedule.currentLevelIndex
+      )
     }
   }