fix intersection tests to support the latest apache-beam version

mc-digital · Oct 19, 2021 · b8c5466 · b8c5466
1 parent 1884638
commit b8c5466
Showing 1 changed file with 7 additions and 7 deletions.
diff --git 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: