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%)