def METHOD_NAME(project, dataset, src_dataset):
    """Update the schema.yaml files in each query."""
    sql_root = ROOT / "sql" / project / dataset
    for path in sql_root.glob("*"):
        print(f"fetching schema for {path.name}")
        # we can update the schema with the development version of the schema
        schema = dict(fields=get_schema(f"{src_dataset}.{path.name}", project))
        with (path / "schema.yaml").open("w") as fp:
            yaml.dump(schema, fp)