in migration_toolkit/sql_generators/copy_rows/ddl_parser.py [0:0]
def _to_dict(schema):
d = {}
for column in schema:
column = DDLParser._strip_trailing_comma(column.strip())
name: str = DDLParser._column_name(column)
if DDLParser._is_metadata_column(name):
logger.debug(f"Skipping metadata column {column}")
continue
try:
source_type: BigQueryType = DDLParser._column_schema(column)
except ValueError:
raise ValueError(
"Expected column description to in the format of '<column_name>"
f" <column_type>' but got: '{column}'"
)
d[name] = source_type
return d