You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bo...@apache.org on 2020/01/23 20:52:18 UTC

[beam] branch release-2.19.0 updated: Make apply_TestStream not a test b/c Nose thinks it is a test

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

boyuanz pushed a commit to branch release-2.19.0
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/release-2.19.0 by this push:
     new 987b7a4  Make apply_TestStream not a test b/c Nose thinks it is a test
     new 5b71f11  Merge pull request #10675 from boyuanzz/cherry-pick
987b7a4 is described below

commit 987b7a4b5894bc5bbc8881af93125b1d833bf847
Author: Sam Rohde <ro...@gmail.com>
AuthorDate: Fri Jan 17 11:15:51 2020 -0800

    Make apply_TestStream not a test b/c Nose thinks it is a test
    
    (cherry picked from commit 02b2f207998ded82e67167224769157e84c1a2a6)
---
 sdks/python/apache_beam/runners/direct/direct_runner.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/sdks/python/apache_beam/runners/direct/direct_runner.py b/sdks/python/apache_beam/runners/direct/direct_runner.py
index d584f6b..b6902ff 100644
--- a/sdks/python/apache_beam/runners/direct/direct_runner.py
+++ b/sdks/python/apache_beam/runners/direct/direct_runner.py
@@ -118,6 +118,10 @@ class SwitchingDirectRunner(PipelineRunner):
 
     return outputs
 
+  # We must mark this method as not a test or else its name is a matcher for
+  # nosetest tests.
+  apply_TestStream.__test__ = False
+
   def run_pipeline(self, pipeline, options):
 
     from apache_beam.pipeline import PipelineVisitor