diff --git a/sdks/python/apache_beam/typehints/schemas.py b/sdks/python/apache_beam/typehints/schemas.py index 4b312d96ce9f..4e1547d18103 100644 --- a/sdks/python/apache_beam/typehints/schemas.py +++ b/sdks/python/apache_beam/typehints/schemas.py @@ -365,6 +365,8 @@ def typing_from_runner_api( base = self.typing_from_runner_api(base_type) if base == Any: return base + elif isinstance(base, row_type.RowTypeConstraint): + return base else: return Optional[base]