This is an automated email from the ASF dual-hosted git repository.
vterentev pushed a commit to branch fix-postcommit-python
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/fix-postcommit-python by this
push:
new 7126c1a99af Fix debezium output type
7126c1a99af is described below
commit 7126c1a99afd768eda4035f5a2f2dd6676cc9708
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Fri Jul 25 11:27:44 2025 +0400
Fix debezium output type
---
sdks/python/apache_beam/io/debezium.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/io/debezium.py
b/sdks/python/apache_beam/io/debezium.py
index 9e93801852c..e6f3290d06a 100644
--- a/sdks/python/apache_beam/io/debezium.py
+++ b/sdks/python/apache_beam/io/debezium.py
@@ -166,5 +166,5 @@ class ReadFromDebezium(PTransform):
self.URN,
NamedTupleBasedPayloadBuilder(self.params),
self.expansion_service,
- ).with_output_types(str)
+ )
| 'JsonToDict' >> Map(json.loads).with_output_types(dict))
