diff --git a/sdks/python/apache_beam/yaml/standard_io.yaml b/sdks/python/apache_beam/yaml/standard_io.yaml index 3d619c187076..ddc3c7662a65 100644 --- a/sdks/python/apache_beam/yaml/standard_io.yaml +++ b/sdks/python/apache_beam/yaml/standard_io.yaml @@ -45,9 +45,15 @@ type: beamJar transforms: 'ReadFromBigQuery': 'beam:schematransform:org.apache.beam:bigquery_storage_read:v1' - 'WriteToBigQuery': 'beam:schematransform:org.apache.beam:bigquery_storage_write:v2' + 'WriteToBigQuery': 'beam:schematransform:org.apache.beam:bigquery_write:v1' config: gradle_target: 'sdks:java:extensions:sql:expansion-service:shadowJar' + managed_replacement: + # Following transforms may be replaced with equivalent managed transforms, + # if the pipelines 'updateCompatibilityBeamVersion' match the provided + # version. + 'ReadFromBigQuery': '2.69.0' + 'WriteToBigQuery': '2.69.0' # Kafka - type: renaming