From b8c54665d0347c7677dc2978f5436d67406232a0 Mon Sep 17 00:00:00 2001 From: mhiro2 Date: Tue, 19 Oct 2021 14:30:01 +0900 Subject: [PATCH] fix intersection tests to support the latest apache-beam version --- tests/test_group.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/tests/test_group.py b/tests/test_group.py index 43bfbd0..740a744 100644 --- a/tests/test_group.py +++ b/tests/test_group.py @@ -64,19 +64,19 @@ class IntersectionTest(unittest.TestCase): def test(self): input_left = [ - {"value1": "AAA", "value2": "XXX"}, - {"value1": "BBB", "value2": "YYY"}, - {"value1": "001", "value2": "001"}, + (("value1", "AAA"), ("value2", "XXX")), + (("value1", "BBB"), ("value2", "YYY")), + (("value1", "001"), ("value2", "001")), ] input_right = [ - {"value1": "AAA", "value2": "XXX"}, - {"value1": "CCC", "value2": "ZZZ"}, - {"value1": "001", "value2": "002"}, + (("value1", "AAA"), ("value2", "XXX")), + (("value1", "CCC"), ("value2", "ZZZ")), + (("value1", "001"), ("value2", "002")), ] expected = [ - {"value1": "AAA", "value2": "XXX"}, + (("value1", "AAA"), ("value2", "XXX")), ] with TestPipeline() as p: