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