[beam] branch master updated (3edc7ac -> ce797f0)

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 3edc7ac  [BEAM-9127] Fix output type declaration in xlang wordcount. (#10605)
     add 43bd561  Automatically convert to with pipeline syntax.
     add 88fa30e  Quick pass through failed auto-conversions.
     add 149b9f7  Automatic conversion of more pipelines.
     add 11f9ada  Fix lint and tests due to autoconversion.
     add efa150d  A couple more conversions.
     add b3a1bdd  Fix lint and tests due to autoconversion.
     add fad9f04  Return non-None result for Dataflow dry run.
     add 5e91757  Fix lint and tests due to autoconversion.
     add ff2e030  lint, reviewer comments
     add 07b379c  lint
     add 8811f69  Merge branch 'master' into with-statement
     add 4ed6084  fix merge
     add ce797f0  Merge pull request #10149 [BEAM-8739] Consistently use with Pipeline(...) syntax

No new revisions were added by this update.

Summary of changes:
 .../apache_beam/examples/cookbook/filters_test.py  |  30 +-
 .../apache_beam/examples/fastavro_it_test.py       |  73 ++-
 .../examples/flink/flink_streaming_impulse.py      |  34 +-
 .../apache_beam/examples/snippets/snippets.py      | 171 +++---
 .../apache_beam/examples/streaming_wordcount.py    |  86 ++-
 .../examples/streaming_wordcount_debugging.py      | 150 +++--
 .../python/apache_beam/examples/wordcount_xlang.py |  15 +-
 sdks/python/apache_beam/io/concat_source_test.py   |   7 +-
 .../io/external/generate_sequence_test.py          |   3 +-
 .../io/external/xlang_parquetio_test.py            |   9 +-
 sdks/python/apache_beam/io/filebasedsource_test.py | 105 ++--
 .../io/gcp/bigquery_io_read_pipeline.py            |  29 +-
 .../apache_beam/io/gcp/bigquery_read_perf_test.py  |  22 +-
 sdks/python/apache_beam/io/gcp/pubsub_test.py      | 141 +++--
 sdks/python/apache_beam/io/parquetio_it_test.py    |  10 +-
 sdks/python/apache_beam/io/sources_test.py         |   7 +-
 sdks/python/apache_beam/io/textio_test.py          | 310 +++++-----
 sdks/python/apache_beam/io/vcfio_test.py           |  25 +-
 sdks/python/apache_beam/pipeline_test.py           | 347 ++++++-----
 .../runners/dataflow/dataflow_runner.py            |   4 +-
 .../runners/dataflow/dataflow_runner_test.py       |  66 +--
 .../runners/dataflow/native_io/iobase_test.py      |   7 +-
 .../runners/dataflow/template_runner_test.py       |  24 +-
 .../runners/interactive/interactive_beam.py        |   7 +-
 sdks/python/apache_beam/testing/test_pipeline.py   |   7 +-
 .../apache_beam/testing/test_pipeline_test.py      |  12 +-
 .../python/apache_beam/testing/test_stream_test.py |  77 ++-
 .../apache_beam/transforms/combiners_test.py       | 300 +++++-----
 .../apache_beam/transforms/dofn_lifecycle_test.py  |  10 +-
 .../apache_beam/transforms/ptransform_test.py      | 639 ++++++++++-----------
 sdks/python/apache_beam/transforms/stats_test.py   | 236 ++++----
 .../transforms_keyword_only_args_test_py3.py       | 173 +++---
 .../apache_beam/transforms/userstate_test.py       |  49 +-
 sdks/python/apache_beam/transforms/util_test.py    | 272 +++++----
 .../apache_beam/typehints/typed_pipeline_test.py   |  25 +-
 35 files changed, 1641 insertions(+), 1841 deletions(-)