This is an automated email from the ASF dual-hosted git repository.
aglinxinyuan pushed a change to branch xinyuan-loop-feb
in repository https://gitbox.apache.org/repos/asf/texera.git
from 528a4784eb Merge branch 'main' into xinyuan-loop-feb
add c1d19afc38 fix: route StateFrame through state.toTuple in
PythonProxyClient
add 555e55df54 Add scheduler jump-to-operator support
add 001a409000 Add scheduler jump test
add eafb7f69a4 Merge branch 'main' into xinyuan-scheduler-jump
add d695dec39b fix fmt
add abad7f1aae Merge branch 'main' into xinyuan-scheduler-jump
add 3926100d51 Merge branch 'main' into xinyuan-scheduler-jump
add 72a3c241e1 Merge branch 'main' into xinyuan-scheduler-jump
add 9c00ac504d Merge branch 'main' into xinyuan-scheduler-jump
add 59e91c93cd Merge branch 'main' into xinyuan-scheduler-jump
add f327f0ca37 Merge branch 'main' into xinyuan-scheduler-jump
add 20e2cedbf7 Refactor jump state into execution coordinator
add 4c8cb5f778 Simplify coordinator jump scheduling
add b7c2e3b900 fix fmt
add 0aa5017689 Clarify jump-to-region API
add 612206f40f Restore iterator-style coordinator wiring
add 86cbdc5e7f fix fmt
add 73d0e2f273 Merge branch 'main' into xinyuan-scheduler-jump
add f726337b3d Merge branch 'main' into xinyuan-scheduler-jump
add baf5dbbe10 fix
add ba6104fef8 fix fmt
add cff7fb1169 Merge branch 'main' into xinyuan-scheduler-jump
add 560b670a67 update
add 3579bc1566 update
add 802bdd0e71 update
add 9f5feab24f Merge branch 'main' into xinyuan-scheduler-jump
add f5ef44748a update
add 0f9a5f89c9 Merge branch 'main' into xinyuan-scheduler-jump
add 83e6fb575b fix fmt
add 178f59b0e2 Merge branch 'main' into xinyuan-scheduler-jump
add 2ab9e001f5 test(amber): expand jump-to-operator-region coordinator
coverage
add 9472125611 feat(amber): require Schedule level keys to be contiguous
from 0
add be4baff90f Merge remote-tracking branch 'origin/main' into
xinyuan-scheduler-jump
add 180f481b37 Merge xinyuan-scheduler-jump into xinyuan-loop-feb
No new revisions were added by this update.
Summary of changes:
.../engine/architecture/rpc/controlcommands.proto | 5 +
.../architecture/rpc/controllerservice.proto | 1 +
.../amber/engine/architecture/rpc/__init__.py | 43 +++++++
.../architecture/controller/Controller.scala | 1 +
.../ControllerAsyncRPCHandlerInitializer.scala | 1 +
.../controller/ControllerProcessor.scala | 11 +-
...ler.scala => JumpToOperatorRegionHandler.scala} | 10 +-
.../pythonworker/PythonProxyClient.scala | 2 +-
.../engine/architecture/scheduling/Schedule.scala | 49 +++++---
.../scheduling/WorkflowExecutionCoordinator.scala | 27 +++--
.../WorkflowExecutionCoordinatorSpec.scala | 125 ++++++++++++++++++++-
11 files changed, 239 insertions(+), 36 deletions(-)
copy
amber/src/main/scala/org/apache/texera/amber/engine/architecture/controller/promisehandlers/{JumpToOperatorHandler.scala
=> JumpToOperatorRegionHandler.scala} (85%)
