# pth_save = os.path.join(pth, 'df_million_trades.parquet') # df_failled1 = pd.read_parquet(pth_save, engine='fastparquet') # df.to_parquet(pth_save , engine='fastparquet', compression='gzip')
# pth_save = os.path.join(pth, 'df_million_trades.parquet') # df_failled1 = pd.read_parquet(pth_save, engine='fastparquet') # df.to_parquet(pth_save , engine='fastparquet', compression='gzip')