You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2020/01/17 22:04:29 UTC

[beam] branch master 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.

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


The following commit(s) were added to refs/heads/master by this push:
     new 02b2f20  Make apply_TestStream not a test b/c Nose thinks it is a test
     new 259c21c  Merge pull request #10630 from rohdesamuel/nose-fix
02b2f20 is described below

commit 02b2f207998ded82e67167224769157e84c1a2a6
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
---
 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