We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 37c7e28 commit 75eda20Copy full SHA for 75eda20
1 file changed
sdks/python/apache_beam/io/gcp/bigquery.py
@@ -2764,9 +2764,6 @@ def expand(self, input):
2764
2765
class ConvertToBeamRows(PTransform):
2766
def __init__(self, schema, dynamic_destinations):
2767
- if not isinstance(schema,
2768
- (bigquery.TableSchema, bigquery.TableFieldSchema)):
2769
- schema = bigquery_tools.get_bq_tableschema(schema)
2770
self.schema = schema
2771
self.dynamic_destinations = dynamic_destinations
2772
0 commit comments