This is an automated email from the ASF dual-hosted git repository.
aglinxinyuan pushed a change to branch xinyuan-angular-20
in repository https://gitbox.apache.org/repos/asf/texera.git
from 0afc6244a3 fix fmt
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 ef66190f22 fix: add missing context switches for repeated state
processing (#4424)
add 05b271c5cc feat(engine): add support for restarting regions (#4441)
add 1ce60d6141 chore(deps): upgrade frontend to Angular 19 (#4445)
add 7a55762e6c Merge branch 'main' into xinyuan-angular-20
No new revisions were added by this update.
Summary of changes:
.github/workflows/github-action-build.yml | 5 +-
amber/requirements.txt | 2 -
.../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 +
.../core/architecture/managers/pause_manager.py | 7 +-
.../architecture/managers/test_debug_manager.py | 116 +
.../managers/tuple_processing_manager.py | 3 +-
.../core/architecture/rpc/async_rpc_server.py | 21 +-
.../main/python/core/runnables/data_processor.py | 1 +
amber/src/main/python/core/runnables/main_loop.py | 15 +-
.../main/python/core/runnables/test_main_loop.py | 120 +-
.../architecture/common/AmberProcessor.scala | 5 +-
.../controller/execution/WorkflowExecution.scala | 14 +
.../promisehandlers/ReconfigurationHandler.scala | 47 +-
.../messaginglayer/NetworkInputGateway.scala | 6 +
.../messaginglayer/NetworkOutputGateway.scala | 6 +
.../scheduling/RegionExecutionCoordinator.scala | 17 +-
.../scheduling/WorkflowExecutionCoordinator.scala | 8 +-
.../engine/architecture/worker/DataProcessor.scala | 11 +-
.../engine/architecture/worker/PauseType.scala | 2 -
.../amberexception/BreakpointException.scala | 24 -
.../amber/engine/common/rpc/AsyncRPCClient.scala | 8 +-
.../service/ExecutionReconfigurationService.scala | 136 +-
.../breakpoint/ExceptionBreakpointSpec.scala | 298 -
.../architecture/control/TrivialControlSpec.scala | 45 +-
.../control/utils/TrivialControlTester.scala | 14 +-
.../messaginglayer/NetworkInputGatewaySpec.scala | 12 +
.../apache/texera/amber/engine/e2e/PauseSpec.scala | 16 +-
.../amber/engine/e2e/ReconfigurationSpec.scala | 29 +-
.../apache/texera/amber/engine/e2e/TestUtils.scala | 24 +-
.../workflow/WorkflowExecutionsResourceSpec.scala | 40 +
.../ExecutionReconfigurationServiceSpec.scala | 149 +
frontend/yarn.lock | 23868 -------------------
35 files changed, 1238 insertions(+), 24366 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
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/web/service/ExecutionReconfigurationServiceSpec.scala
