This is an automated email from the ASF dual-hosted git repository.
aglinxinyuan pushed a change to branch xinyuan-state-only
in repository https://gitbox.apache.org/repos/asf/texera.git
from 2716fc5e0a Merge branch 'main' into xinyuan-state-only
add 1045997b0e ci: protect future release branches via ASF rulesets (#4582)
add 3ae4ce38d8 test(amber): add unit test coverage for SchedulingUtils
(#4566)
add 20cce23fc6 test(amber): add unit test coverage for ExecutionUtils
(#4570)
add 9eb33cef0b fix(amber): make region kill synchronous before scheduling
next region (#4557)
add 9474b9de2b fix(amber): emit Python operator state outputs reliably
(#4560)
add 28a412bd92 Merge branch 'main' into xinyuan-state-only
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 29 ++
.../main/python/core/runnables/data_processor.py | 42 ++-
amber/src/main/python/core/runnables/main_loop.py | 1 -
.../main/python/core/runnables/test_main_loop.py | 288 +++++++++++++++++
.../controller/WorkflowScheduler.scala | 2 +
.../WorkerExecutionCompletedHandler.scala | 6 +-
.../scheduling/RegionExecutionCoordinator.scala | 56 +++-
.../scheduling/ScheduleGenerator.scala | 33 --
.../architecture/scheduling/SchedulingUtils.scala | 2 +-
.../scheduling/WorkflowExecutionCoordinator.scala | 45 ++-
.../worker/promisehandlers/EndHandler.scala | 2 +-
.../controller/execution/ExecutionUtilsSpec.scala | 340 +++++++++++++++++++++
.../scheduling/RegionCoordinatorTestSupport.scala | 241 +++++++++++++++
.../RegionExecutionCoordinatorSpec.scala | 202 ++++++++++++
.../scheduling/SchedulingUtilsSpec.scala | 140 +++++++++
.../WorkflowExecutionCoordinatorSpec.scala | 93 ++++++
.../worker/promisehandlers/EndHandlerSpec.scala | 113 +++++++
17 files changed, 1561 insertions(+), 74 deletions(-)
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/controller/execution/ExecutionUtilsSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/scheduling/RegionCoordinatorTestSupport.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/scheduling/RegionExecutionCoordinatorSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/scheduling/SchedulingUtilsSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/scheduling/WorkflowExecutionCoordinatorSpec.scala
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/EndHandlerSpec.scala
