fix
This commit is contained in:
@@ -1853,7 +1853,11 @@ def dataprep(rowdatadf, id=0, bands=True, barchart=True, otwpower=True,
|
||||
|
||||
filename = 'media/strokedata_{id}.parquet.gz'.format(id=id)
|
||||
df = dd.from_pandas(data, npartitions=1)
|
||||
df.to_parquet(filename, engine='fastparquet', compression='GZIP')
|
||||
try:
|
||||
df.to_parquet(filename, engine='fastparquet', compression='GZIP')
|
||||
except FileNotFoundError:
|
||||
df2 = dd.from_pandas(df, npartitions=1)
|
||||
df2.to_parquet(filename, engine='fastparquet', compression='GZIP')
|
||||
|
||||
return data
|
||||
|
||||
|
||||
Reference in New Issue
Block a user