def _to_dict()

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