This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 077f4ca Add --sdk_container_image Python WorkerOption (#14557)
add 2012180 [BEAM-2085] Add capability to declare resource hints in
Python pipeline transforms. (#14390)
No new revisions were added by this update.
Summary of changes:
.../pipeline/src/main/proto/beam_runner_api.proto | 12 ++
.../python/apache_beam/options/pipeline_options.py | 11 +
sdks/python/apache_beam/pipeline.py | 38 +++-
sdks/python/apache_beam/pipeline_test.py | 203 ++++++++++++++++++
sdks/python/apache_beam/portability/common_urns.py | 2 +
.../runners/dataflow/dataflow_runner.py | 14 +-
.../runners/dataflow/dataflow_runner_test.py | 30 +++
.../runners/dataflow/internal/apiclient_test.py | 54 ++---
.../apache_beam/runners/dataflow/internal/names.py | 1 +
.../python/apache_beam/runners/pipeline_context.py | 57 ++++-
.../apache_beam/runners/pipeline_context_test.py | 32 ++-
sdks/python/apache_beam/transforms/core.py | 2 +-
sdks/python/apache_beam/transforms/environments.py | 235 ++++++++++++++-------
.../apache_beam/transforms/environments_test.py | 11 +
sdks/python/apache_beam/transforms/ptransform.py | 30 +++
.../apache_beam/transforms/ptransform_test.py | 12 ++
sdks/python/apache_beam/transforms/resources.py | 216 +++++++++++++++++++
.../apache_beam/transforms/resources_test.py | 66 ++++++
18 files changed, 883 insertions(+), 143 deletions(-)
create mode 100644 sdks/python/apache_beam/transforms/resources.py
create mode 100644 sdks/python/apache_beam/transforms/resources_test.py
