diff --git a/sdks/python/apache_beam/typehints/schemas.py b/sdks/python/apache_beam/typehints/schemas.py index fea9b3534b0..2c5d35a68cc 100644 --- a/sdks/python/apache_beam/typehints/schemas.py +++ b/sdks/python/apache_beam/typehints/schemas.py @@ -513,13 +513,17 @@ def typing_from_runner_api( # generate a NamedTuple type to use. fields = named_fields_from_schema(schema) + descriptions = { + field.name: field.description + for field in schema.fields + } result = row_type.RowTypeConstraint.from_fields( fields=fields, schema_id=schema.id, schema_options=schema_options, field_options=field_options, schema_registry=self.schema_registry, - ) + field_descriptions=descriptions or None) return result else: return row_type.RowTypeConstraint.from_user_type(