This is an automated email from the ASF dual-hosted git repository.
Xiao-zhen-Liu pushed a change to branch xinyuan-fix-state-processing
in repository https://gitbox.apache.org/repos/asf/texera.git
from b40da17798 fix fmt
add e635dd027d feat(amber): Re-enable operator reconfiguration in Amber
(#4220)
add 76480d9884 perf(amber): exit TrivialControlSpec receiveWhile early
(#4506)
add 2fb66747ab chore(amber): remove dead tuple-level breakpoint test and
exception class (#4504)
add 04cf85ac75 perf(ci): combine sbt lint steps; keep test step separate
(#4508)
add b2f178d585 test(amber-python): add unit tests for Udon debugger (#4510)
add 20c3a57eac perf(amber): replace Thread.sleep with event-driven waits
in e2e specs (#4518)
add f59dde5aa1 perf(ci): use uv pip for faster Python dep install (#4521)
add a6ae296e10 test(amber-python): per-channel sync in
test_main_loop_thread_can_align_ecm (#4526)
add 954f41b62e chore(amber): remove typing and dataclasses backport
packages (#4523)
add d33603a452 fix(amber-python): harden Udon debug command translation
against bad input (#4512)
add a099f0c9bc chore(amber): remove unused SchedulerTimeSlotExpiredPause
(#4533)
add 871017e2b3 test(amber-python): add unit tests for evaluate-expression
and retry-current-tuple handlers (#4520)
add 23901be24b fix(amber): wire ExecutionReconfigurationService back to
the engine (#4531)
add 398ae12e13 Merge branch 'main' into xinyuan-fix-state-processing
No new revisions were added by this update.
Summary of changes:
.github/workflows/github-action-build.yml | 19 +-
amber/requirements.txt | 2 -
.../engine/architecture/rpc/controlcommands.proto | 22 +-
.../architecture/rpc/controllerservice.proto | 1 +
.../engine/architecture/rpc/workerservice.proto | 1 +
.../handlers/control/debug_command_handler.py | 45 ++-
.../handlers/control/test_debug_command_handler.py | 195 ++++++++++++
.../control/test_evaluate_expression_handler.py | 156 ++++++++++
.../control/test_replay_current_tuple_handler.py | 139 +++++++++
.../handlers/control/update_executor_handler.py | 27 +-
.../core/architecture/managers/pause_manager.py | 7 +-
.../architecture/managers/test_debug_manager.py | 116 ++++++++
.../rpc/async_rpc_handler_initializer.py | 4 +
.../core/architecture/rpc/async_rpc_server.py | 21 +-
amber/src/main/python/core/runnables/main_loop.py | 21 +-
.../main/python/core/runnables/network_receiver.py | 5 +-
.../main/python/core/runnables/test_main_loop.py | 59 +++-
.../amber/engine/architecture/rpc/__init__.py | 99 +++++--
.../ControllerAsyncRPCHandlerInitializer.scala | 3 +-
.../promisehandlers/ReconfigurationHandler.scala | 141 +++++++++
.../engine/architecture/worker/DataProcessor.scala | 11 +-
.../DataProcessorRPCHandlerInitializer.scala | 28 +-
.../engine/architecture/worker/PauseType.scala | 2 -
.../InitializeExecutorHandler.scala | 18 +-
...erHandler.scala => UpdateExecutorHandler.scala} | 18 +-
.../common}/FriesReconfigurationAlgorithm.scala | 55 ++--
.../amberexception/BreakpointException.scala | 24 --
.../service/ExecutionReconfigurationService.scala | 136 +++++----
.../breakpoint/ExceptionBreakpointSpec.scala | 298 -------------------
.../architecture/control/TrivialControlSpec.scala | 45 +--
.../apache/texera/amber/engine/e2e/PauseSpec.scala | 16 +-
.../amber/engine/e2e/ReconfigurationSpec.scala | 327 +++++++++++++++++++++
.../apache/texera/amber/engine/e2e/TestUtils.scala | 24 +-
.../ExecutionReconfigurationServiceSpec.scala | 149 ++++++++++
.../texera/amber/operator/TestOperators.scala | 20 ++
35 files changed, 1687 insertions(+), 567 deletions(-)
create mode 100644
amber/src/main/python/core/architecture/handlers/control/test_debug_command_handler.py
create mode 100644
amber/src/main/python/core/architecture/handlers/control/test_evaluate_expression_handler.py
create mode 100644
amber/src/main/python/core/architecture/handlers/control/test_replay_current_tuple_handler.py
create mode 100644
amber/src/main/python/core/architecture/managers/test_debug_manager.py
create mode 100644
amber/src/main/scala/org/apache/texera/amber/engine/architecture/controller/promisehandlers/ReconfigurationHandler.scala
copy
amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/{FlushNetworkBufferHandler.scala
=> UpdateExecutorHandler.scala} (71%)
rename amber/src/main/scala/org/apache/texera/{web/service =>
amber/engine/common}/FriesReconfigurationAlgorithm.scala (72%)
delete mode 100644
amber/src/main/scala/org/apache/texera/amber/engine/common/amberexception/BreakpointException.scala
delete mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/breakpoint/ExceptionBreakpointSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/e2e/ReconfigurationSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/web/service/ExecutionReconfigurationServiceSpec.scala
