You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by cc...@apache.org on 2018/08/14 17:57:08 UTC

[beam] 01/01: Merge pull request #6217 from udim/pubsub-directrunner

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 <ch...@users.noreply.github.com>
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(-)