def _column_schema()

in migration_toolkit/sql_generators/copy_rows/ddl_parser.py [0:0]

• 10 lines of code
• 4 McCabe index (conditional complexity)

  def _column_schema(column: str) -> BigQueryType:
    column_schema = column.split()[1:]
    if column_schema[0].startswith("NUMERIC"):
      return BigQueryType.NUMERIC
    elif column_schema[0].startswith("BIGNUMERIC"):
      return BigQueryType.BIGNUMERIC
    elif column_schema[0].startswith("STRING"):
      return BigQueryType.STRING
    else:
      return BigQueryType(column_schema[0])