Updates YAML Database transforms to use managed I/O by default (#37923)

chamikaramj · web-flow · commit 79c52affb1dc · 2026-03-24T10:18:28.000-04:00
diff --git a/sdks/python/apache_beam/yaml/standard_io.yaml b/sdks/python/apache_beam/yaml/standard_io.yaml
@@ -240,32 +240,32 @@
         driver_jars: ''
         jdbc_type: ''
       'ReadFromPostgres':
-        connection_init_sql: ''
+        connection_init_sql: []
         driver_class_name: ''
         driver_jars: ''
         jdbc_type: ''
       'WriteToPostgres':
-        connection_init_sql: ''
+        connection_init_sql: []
         driver_class_name: ''
         driver_jars: ''
         jdbc_type: ''
       'ReadFromOracle':
-        connection_init_sql: ''
+        connection_init_sql: []
         driver_class_name: ''
         driver_jars: ''
         jdbc_type: ''
       'WriteToOracle':
-        connection_init_sql: ''
+        connection_init_sql: []
         driver_class_name: ''
         driver_jars: ''
         jdbc_type: ''
       'ReadFromSqlServer':
-        connection_init_sql: ''
+        connection_init_sql: []
         driver_class_name: ''
         driver_jars: ''
         jdbc_type: ''
       'WriteToSqlServer':
-        connection_init_sql: ''
+        connection_init_sql: []
         driver_class_name: ''
         driver_jars: ''
         jdbc_type: ''
@@ -284,6 +284,16 @@
         'WriteToSqlServer': 'beam:schematransform:org.apache.beam:sql_server_write:v1'
       config:
         gradle_target: 'sdks:java:extensions:schemaio-expansion-service:shadowJar'
+        managed_replacement:
+          # Following transforms may be replaced with equivalent managed transforms,
+          # if the pipelines 'updateCompatibilityBeamVersion' match the provided
+          # version.
+          'ReadFromPostgres': '2.73.0'
+          'WriteToPostgres': '2.73.0'
+          'ReadFromMySql': '2.73.0'
+          'WriteToMySql': '2.73.0'
+          'ReadFromSqlServer': '2.73.0'
+          'WriteToSqlServer': '2.73.0'
 
 # Spanner
 - type: renaming
