data_base ❭ isf_data_base ❭ IO ❭ LoaderDumper ❭ dask_to_parquet ❭ save_helper

save_helper¶

data_base.isf_data_base.IO.LoaderDumper.dask_to_parquet.save_helper(savedir, delayed_df, n_partitions, partition)¶

Save a single partition of a dask dataframe to a parquet file

Parameters:¶

• savedir (str) – Directory where the parquet files are stored

• delayed_df (dask.dataframe) – Dask dataframe

• n_partitions (int) – Number of partitions

• partition (int) – Partition number

Returns:¶

None