sander/rowsandall
Private
Public Access
1
0
Fork 0
Code Activity

small improv

Browse Source
This commit is contained in:
Sander Roosendaal
2019-12-07 13:53:56 +01:00
parent d012a34dcd
commit 1e57f58445
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
rowers/dataprep.py
View File

@@ -31,6 +31,7 @@ import dask.dataframe as dd
from dask.delayed import delayed from dask.delayed import delayed
import pyarrow.parquet as pq import pyarrow.parquet as pq
import pyarrow as pa import pyarrow as pa
from pyarrow.lib import ArrowInvalid
from django.utils import timezone from django.utils import timezone
from django.utils.timezone import get_current_timezone from django.utils.timezone import get_current_timezone
@@ -1872,7 +1873,7 @@ def getsmallrowdata_db(columns, ids=[], doclean=True,workstrokesonly=True,comput
else: else:
try: try:
df = pd.read_parquet(csvfilenames[0],columns=columns) df = pd.read_parquet(csvfilenames[0],columns=columns)
except OSError: except (OSError,ArrowInvalid):
rowdata,row = getrowdata(id=ids[0]) rowdata,row = getrowdata(id=ids[0])
if rowdata and len(rowdata.df): if rowdata and len(rowdata.df):
data = dataprep(rowdata.df,id=ids[0],bands=True,otwpower=True,barchart=True) data = dataprep(rowdata.df,id=ids[0],bands=True,otwpower=True,barchart=True)