diff --git a/analyse_properties/main.py b/analyse_properties/main.py index f3c27f9..ac1c899 100644 --- a/analyse_properties/main.py +++ b/analyse_properties/main.py @@ -91,7 +91,7 @@ class DeduplicateByID(beam.DoFn): def process(self, element): if len(list(element[1])) > 0: - deduplicated_element = list(list(element[0]), list([element[1][0]])) + deduplicated_element = (list(element[0]), [list(element[1])[0]]) yield deduplicated_element else: yield element