This is an automated email from the ASF dual-hosted git repository.
vterentev pushed a commit to branch fix-python-xlang
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/fix-python-xlang by this push:
new 8cfb7b6bd88 Refactoring
8cfb7b6bd88 is described below
commit 8cfb7b6bd886285fd252efc3fc46b3c679241d48
Author: Vitaly Terentyev <vitaly.terent...@akvelon.com>
AuthorDate: Tue Jun 3 16:31:00 2025 +0400
Refactoring
---
sdks/python/apache_beam/coders/row_coder.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/coders/row_coder.py
b/sdks/python/apache_beam/coders/row_coder.py
index fee5164ee59..520473a117d 100644
--- a/sdks/python/apache_beam/coders/row_coder.py
+++ b/sdks/python/apache_beam/coders/row_coder.py
@@ -162,7 +162,7 @@ def _nonnull_coder_from_type(field_type):
elif type_info == "array_type":
return IterableCoder(_coder_from_type(field_type.array_type.element_type))
elif type_info == "iterable_type":
- return IterableCoder(_coder_from_type(field_type.array_type.element_type))
+ return
IterableCoder(_coder_from_type(field_type.iterable_type.element_type))
elif type_info == "map_type":
return MapCoder(
_coder_from_type(field_type.map_type.key_type),
