# 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')