You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2017/03/21 17:39:05 UTC
[2/3] beam git commit: Fix bad test obscured by falsely passing
assert_that.
Fix bad test obscured by falsely passing assert_that.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/47da10cf
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/47da10cf
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/47da10cf
Branch: refs/heads/master
Commit: 47da10cfc21e3344bd198e572528a02fcf1caec3
Parents: c39b02d
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Tue Mar 21 00:41:06 2017 -0700
Committer: Robert Bradshaw <ro...@google.com>
Committed: Tue Mar 21 10:38:37 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/transforms/window_test.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/47da10cf/sdks/python/apache_beam/transforms/window_test.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/transforms/window_test.py b/sdks/python/apache_beam/transforms/window_test.py
index 99be02c..11c8a68 100644
--- a/sdks/python/apache_beam/transforms/window_test.py
+++ b/sdks/python/apache_beam/transforms/window_test.py
@@ -142,7 +142,7 @@ class WindowTest(unittest.TestCase):
def timestamped_key_values(self, pipeline, key, *timestamps):
return (pipeline | 'start' >> Create(timestamps)
- | Map(lambda x: WindowedValue((key, x), x, [])))
+ | Map(lambda x: WindowedValue((key, x), x, [GlobalWindow()])))
def test_sliding_windows(self):
p = TestPipeline()