From 14487860326864789c66f77710792e4d908b5329 Mon Sep 17 00:00:00 2001 From: Yi Hu Date: Tue, 14 Oct 2025 11:36:38 -0400 Subject: [PATCH] Revert "Per element schema parsing in ConvertToBeamRows (#36393)" This reverts commit 1a6ec3a08269c2a9b76778f7bc1c3aec65ef119f. --- sdks/python/apache_beam/io/gcp/bigquery.py | 3 --- 1 file changed, 3 deletions(-) diff --git a/sdks/python/apache_beam/io/gcp/bigquery.py b/sdks/python/apache_beam/io/gcp/bigquery.py index 7310bbdc9fb6..0905ba764deb 100644 --- a/sdks/python/apache_beam/io/gcp/bigquery.py +++ b/sdks/python/apache_beam/io/gcp/bigquery.py @@ -2764,9 +2764,6 @@ def expand(self, input): class ConvertToBeamRows(PTransform): def __init__(self, schema, dynamic_destinations): - if not isinstance(schema, - (bigquery.TableSchema, bigquery.TableFieldSchema)): - schema = bigquery_tools.get_bq_tableschema(schema) self.schema = schema self.dynamic_destinations = dynamic_destinations