in src/package/dataplexutils/metadata/wizard.py [0:0]
def _update_table_schema(self, table_fqn, schema):
"""Updates the schema of a BigQuery table.
Args:
table_fqn (str): The fully qualified name of the table
(e.g., 'project.dataset.table')
schema (list): List of SchemaField objects representing the new schema
Raises:
Exception: If there is an error updating the schema
"""
try:
table = self._cloud_clients[constants["CLIENTS"]["BIGQUERY"]].get_table(
table_fqn
)
table.schema = schema
_ = self._cloud_clients[constants["CLIENTS"]["BIGQUERY"]].update_table(
table, ["schema"]
)
except Exception as e:
logger.error(f"Exception: {e}.")
raise e