def rewrite_to_sqlite()

in de/fileutils.py [0:0]

• 3 lines of code
• 1 McCabe index (conditional complexity)

def rewrite_to_sqlite(src, dest, **kwargs):
    """
    Reads a Parquet file and writes it out to a SQLite database.

    :param src: Path to the source Parquet file.
    :param dest: Path to the destination SQLite database.
    """
    table = pq.read_table(src)
    table.to_pandas().to_sql(dest.stem, dest, if_exists="replace", **kwargs)