def METHOD_NAME(self, schema, query):
    results, error = self.run_query(query, None)
    if error is not None:
        self._handle_run_query_error(error)
    results = json_loads(results)
    for row in results["rows"]:
        if row["TABLE_SCHEMA"] != "public":
            table_name = "{}.{}".format(row["TABLE_SCHEMA"], row["TABLE_NAME"])
        else:
            table_name = row["TABLE_NAME"]
        if table_name not in schema:
            schema[table_name] = {"name": table_name, "columns": []}
        schema[table_name]["columns"].append(row["COLUMN_NAME"])