tested

2024-04-08 19:56:38 +02:00
parent 114e049ebd
commit c04c45dd03
3 changed files with 11 additions and 6 deletions
--- a/rowers/dataroutines.py
+++ b/rowers/dataroutines.py
@@ -1875,7 +1875,9 @@ def dataprep(rowdatadf, id=0, bands=True, barchart=True, otwpower=True,
        except FileNotFoundError:
            df2 = dd.from_pandas(df, npartitions=1)
            df2.to_parquet(filename, engine='fastparquet', compression='GZIP')
-
+        except FileExistsError:
+            os.remove(filename)
+            df.to_parquet(filename, engine='fastparquet', compression='GZIP')
    return data