This is an automated email from the ASF dual-hosted git repository.
damondouglas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from b795a61f094 Adds null checks when accessing OperationalLimits in
config since they might not have been set yet. (#32053)
add 202fa56be77 Enable ExternalWorkerService during Prism Runner lifecycle
(#32057)
No new revisions were added by this update.
Summary of changes:
runners/prism/java/build.gradle | 2 +
.../apache/beam/runners/prism/WorkerService.java | 116 +++++++++++++++++++++
.../beam/runners/prism/WorkerServiceTest.java | 85 +++++++++++++++
3 files changed, 203 insertions(+)
create mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/WorkerService.java
create mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/WorkerServiceTest.java