Yapf

tvalentyn · tvalentyn · commit 07e60d7b4c94 · 2022-01-13T19:13:54.000-08:00
diff --git a/sdks/python/apache_beam/runners/direct/transform_evaluator.py b/sdks/python/apache_beam/runners/direct/transform_evaluator.py
@@ -938,8 +938,7 @@ def process_element(self, element):
     assert not self.global_state.get_state(
         None, _GroupByKeyOnlyEvaluator.COMPLETION_TAG)
     if (isinstance(element, WindowedValue) and
-        isinstance(element.value, abc.Iterable) and
-        len(element.value) == 2):
+        isinstance(element.value, abc.Iterable) and len(element.value) == 2):
       k, v = element.value
       encoded_k = self.key_coder.encode(k)
       state = self._step_context.get_keyed_state(encoded_k)
