def check_geospatial_schema()

in data/geospatial/geospatial-gen.py [0:0]


def check_geospatial_schema(name):
    file = parquet.ParquetFile(HERE / name)

    col = file.schema.column(2)
    col_dict = json.loads(col.logical_type.to_json())
    col_type = col_dict["Type"]
    if col_type != "Geometry":
        raise ValueError(f"Expected 'Geometry' logical type but got '{col_type}'")