You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/06/07 04:22:01 UTC
[beam] branch nightly-refs/heads/master updated (4dce7b8857f -> 3c623abd631)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 4dce7b8857f [BEAM-14556] Honor the formatter installed on the root handler. (#17820)
add 9a7c9ce9b84 [Fixes #18679] Ensure that usage of metrics on a template job reports an error (#18905)
add 4b623313707 Clean up uses of == instead of === in ts sdk (#17732)
add 420aef2feda Update Jira -> Issues in the Readme
add 169cf80b082 Merge pull request #21718 from damccorm/patch-1
add 22276b05414 Add an option to run Python operations in-line when invoked as a remote runner.
add 62a8d00a5d8 Pass options underlying runner in remote job service.
add 4405056c783 Comment, lint fixes.
add 4788b07601b Merge pull request #19266 Python ULR inline option.
add 93002d6e9ab Populate missing display data for remotely expanded transforms.
add 88fc2ea1126 Merge pull request #19267 Populate missing display data for remotely expanded transforms.
add 044313637c9 Mount GCP credentials in local docker environments. (#19265)
add 45a80f75b6d [BEAM-14471] Fix PytestUnknownMarkingWarning
add ba579794b44 Merge pull request #17825: [BEAM-14471] Fix PytestUnknownMarkingWarning
add 7445b9535a9 [BEAM-14068]Add Pytorch inference IT test and example (#17462)
add 3c623abd631 [Playground] [Hotfix] Remove autoscrolling from embedded editor (#21717)
No new revisions were added by this update.
Summary of changes:
README.md | 6 +-
build.gradle.kts | 7 +-
playground/frontend/lib/constants/params.dart | 1 +
.../modules/editor/components/editor_textarea.dart | 6 +-
.../components/embedded_editor.dart | 1 +
.../components/playground_page_providers.dart | 3 +-
.../pages/playground/states/examples_state.dart | 20 ++-
.../beam/runners/dataflow/DataflowMetrics.java | 9 +-
.../beam/runners/dataflow/DataflowPipelineJob.java | 8 +-
.../runners/dataflow/util/DataflowTemplateJob.java | 6 +
.../beam/runners/dataflow/DataflowMetricsTest.java | 125 +++++++++++-------
.../apache_beam/examples/inference}/__init__.py | 0
.../inference/pytorch_image_classification.py | 146 +++++++++++++++++++++
sdks/python/apache_beam/io/filesystems_test.py | 8 +-
.../ml/inference/pytorch_inference_it_test.py | 95 ++++++++++++++
.../ml/inference/torch_tests_requirements.txt} | 5 +-
.../python/apache_beam/options/pipeline_options.py | 7 +
.../runners/dataflow/dataflow_job_service.py | 25 +---
.../runners/portability/fn_api_runner/fn_runner.py | 40 +++++-
.../portability/fn_api_runner/worker_handlers.py | 26 +++-
.../runners/portability/local_job_service.py | 17 ++-
sdks/python/apache_beam/transforms/environments.py | 4 -
sdks/python/apache_beam/transforms/external.py | 1 +
sdks/python/pytest.ini | 3 +-
sdks/python/scripts/run_integration_test.sh | 19 ++-
sdks/python/test-suites/dataflow/build.gradle | 2 +-
sdks/python/test-suites/direct/common.gradle | 33 +++++
sdks/typescript/README.md | 2 +-
.../typescript/src/apache_beam/coders/js_coders.ts | 4 +-
.../src/apache_beam/coders/required_coders.ts | 12 +-
.../typescript/src/apache_beam/coders/row_coder.ts | 13 +-
.../src/apache_beam/coders/standard_coders.ts | 2 +-
.../src/apache_beam/internal/pipeline.ts | 14 +-
sdks/typescript/src/apache_beam/pvalue.ts | 12 +-
.../src/apache_beam/runners/artifacts.ts | 6 +-
.../src/apache_beam/runners/direct_runner.ts | 11 +-
.../apache_beam/runners/portable_runner/runner.ts | 6 +-
sdks/typescript/src/apache_beam/runners/runner.ts | 12 +-
sdks/typescript/src/apache_beam/serialization.ts | 2 +-
.../src/apache_beam/transforms/external.ts | 16 ++-
.../src/apache_beam/transforms/flatten.ts | 2 +-
.../apache_beam/transforms/group_and_combine.ts | 12 +-
.../src/apache_beam/transforms/internal.ts | 2 +-
.../typescript/src/apache_beam/transforms/pardo.ts | 16 ++-
sdks/typescript/src/apache_beam/transforms/sql.ts | 9 +-
.../src/apache_beam/transforms/transform.ts | 6 +-
.../src/apache_beam/transforms/window.ts | 2 +-
.../src/apache_beam/transforms/windowings.ts | 2 +-
sdks/typescript/src/apache_beam/utils/service.ts | 8 +-
.../typescript/src/apache_beam/worker/operators.ts | 40 +++---
.../src/apache_beam/worker/pardo_context.ts | 20 ++-
sdks/typescript/src/apache_beam/worker/state.ts | 8 +-
sdks/typescript/src/apache_beam/worker/worker.ts | 12 +-
sdks/typescript/test/standard_coders_test.ts | 2 +-
sdks/typescript/test/worker_test.ts | 6 +-
55 files changed, 652 insertions(+), 230 deletions(-)
copy {.test-infra/jenkins/dependency_check => sdks/python/apache_beam/examples/inference}/__init__.py (100%)
create mode 100644 sdks/python/apache_beam/examples/inference/pytorch_image_classification.py
create mode 100644 sdks/python/apache_beam/ml/inference/pytorch_inference_it_test.py
copy sdks/python/{.coveragerc => apache_beam/ml/inference/torch_tests_requirements.txt} (94%)