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