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 6afa12fefced45b79aecb0c3ca6040757acd12cd Merge: 23abb73 64120d6 Author: Charles Chen <[email protected]> AuthorDate: Thu Jul 26 15:13:39 2018 -0700 Merge pull request #5952 from udim/pubsub-api-2 [BEAM-3744] Python PubSub API Fixes and Tests .../examples/complete/game/game_stats.py | 4 +- .../examples/complete/game/leader_board.py | 4 +- .../apache_beam/examples/streaming_wordcount.py | 10 +- .../examples/streaming_wordcount_debugging.py | 4 +- .../apache_beam/examples/windowed_wordcount.py | 2 +- sdks/python/apache_beam/io/gcp/pubsub.py | 205 ++++++++---- .../apache_beam/io/gcp/pubsub_integration_test.py | 144 +++++++++ .../gcp/pubsub_it_pipeline.py} | 77 ++--- sdks/python/apache_beam/io/gcp/pubsub_test.py | 348 ++++++++++++++++----- .../apache_beam/io/gcp/tests/pubsub_matcher.py | 42 ++- .../io/gcp/tests/pubsub_matcher_test.py | 79 ++++- .../runners/dataflow/dataflow_runner.py | 14 +- .../apache_beam/runners/direct/direct_runner.py | 120 +++---- .../runners/direct/transform_evaluator.py | 2 +- sdks/python/apache_beam/utils/annotations.py | 2 +- 15 files changed, 795 insertions(+), 262 deletions(-)
