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 45bcb38207 Merge branch 'main' into xinyuan-loop-feb
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 95bd9246d8 Merge branch 'main' into xinyuan-loop-feb
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 | 23 +-
.../architecture/rpc/controllerservice.proto | 1 +
.../engine/architecture/rpc/workerservice.proto | 1 +
.../handlers/control/test_debug_command_handler.py | 195 +++++++++++++
.../handlers/control/update_executor_handler.py | 27 +-
.../architecture/managers/test_debug_manager.py | 116 ++++++++
.../rpc/async_rpc_handler_initializer.py | 4 +
amber/src/main/python/core/runnables/main_loop.py | 8 +-
.../main/python/core/runnables/network_receiver.py | 5 +-
.../main/python/core/runnables/test_main_loop.py | 59 +++-
.../amber/engine/architecture/rpc/__init__.py | 183 ++++++++++--
.../ControllerAsyncRPCHandlerInitializer.scala | 3 +-
.../promisehandlers/ReconfigurationHandler.scala | 124 ++++++++
.../DataProcessorRPCHandlerInitializer.scala | 28 +-
.../InitializeExecutorHandler.scala | 18 +-
...erHandler.scala => UpdateExecutorHandler.scala} | 18 +-
.../common}/FriesReconfigurationAlgorithm.scala | 55 ++--
.../amberexception/BreakpointException.scala | 24 --
.../breakpoint/ExceptionBreakpointSpec.scala | 298 -------------------
.../architecture/control/TrivialControlSpec.scala | 45 +--
.../apache/texera/amber/engine/e2e/PauseSpec.scala | 16 +-
.../amber/engine/e2e/ReconfigurationSpec.scala | 317 +++++++++++++++++++++
.../apache/texera/amber/engine/e2e/TestUtils.scala | 24 +-
.../texera/amber/operator/TestOperators.scala | 20 ++
26 files changed, 1157 insertions(+), 476 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/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
