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 <rober...@gmail.com> Authored: Tue Mar 21 00:41:06 2017 -0700 Committer: Robert Bradshaw <rober...@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()