This is an automated email from the ASF dual-hosted git repository.
ningk pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 30b440f Merge pull request #16526 from
roger-mike/fix/pylint/misplaced-bare-raise-and-no-member
add 0e45de7 [BEAM-13812] Integrate DataprocClusterManager into
Interactive Environment
No new revisions were added by this update.
Summary of changes:
.../interactive/dataproc}/__init__.py | 0
.../dataproc/dataproc_cluster_manager.py | 166 +++++++++++++--------
.../dataproc/dataproc_cluster_manager_test.py | 58 +++----
.../runners/interactive/interactive_beam.py | 113 ++++++++++++++
.../runners/interactive/interactive_beam_test.py | 130 ++++++++++++++++
.../runners/interactive/interactive_environment.py | 71 +++++----
.../interactive/interactive_environment_test.py | 69 +++++++++
.../runners/interactive/interactive_runner.py | 70 +++++++++
.../runners/interactive/interactive_runner_test.py | 39 +++++
.../apache_beam/runners/interactive/utils.py | 41 +++++
.../apache_beam/runners/interactive/utils_test.py | 30 ++++
sdks/python/setup.py | 1 +
12 files changed, 669 insertions(+), 119 deletions(-)
copy sdks/python/apache_beam/{testing/load_tests =>
runners/interactive/dataproc}/__init__.py (100%)
