This is an automated email from the ASF dual-hosted git repository. ccy pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 4c693e7aa1ba71fa83370dd383f4bcebe4690b86 Merge: 6a3b615 1918082 Author: Charles Chen <[email protected]> AuthorDate: Tue Aug 14 10:57:03 2018 -0700 Merge pull request #6217 from udim/pubsub-directrunner [BEAM-4275] Implement integration tests for PubSub on DirectRunner .../apache_beam/io/gcp/pubsub_integration_test.py | 80 ++++++++++++++------- .../apache_beam/io/gcp/pubsub_it_pipeline.py | 29 +++++--- sdks/python/apache_beam/io/gcp/pubsub_test.py | 84 ++++++++++++++++++---- sdks/python/apache_beam/runners/__init__.py | 1 + .../runners/dataflow/dataflow_runner.py | 33 +++++---- .../apache_beam/runners/direct/direct_runner.py | 22 ++++-- .../runners/direct/direct_runner_test.py | 11 +++ sdks/python/apache_beam/runners/direct/executor.py | 3 + .../runners/direct/test_direct_runner.py | 56 +++++++++++++++ .../runners/direct/transform_evaluator.py | 11 +-- sdks/python/apache_beam/runners/runner.py | 11 ++- sdks/python/apache_beam/runners/test/__init__.py | 1 + sdks/python/build.gradle | 13 ++-- sdks/python/container/run_validatescontainer.sh | 2 +- sdks/python/scripts/run_postcommit.sh | 32 ++++++--- 15 files changed, 293 insertions(+), 96 deletions(-)
