From 22532bc3c02d04e7fd4a46a7fa2cc61ffce1118a Mon Sep 17 00:00:00 2001
From: Chamikara Jayalath <chamikaramj@gmail.com>
Date: Mon, 23 Mar 2026 13:23:06 -0700
Subject: [PATCH] Updates YAML Database transforms to use managed I/O by
 default

---
 sdks/python/apache_beam/yaml/standard_io.yaml | 22 ++++++++++++++-----
 1 file changed, 16 insertions(+), 6 deletions(-)

diff --git a/sdks/python/apache_beam/yaml/standard_io.yaml b/sdks/python/apache_beam/yaml/standard_io.yaml
index e62b3a562c30..6673222f19a0 100644
--- 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