fixing #591
This commit is contained in:
@@ -648,7 +648,7 @@ def clean_df_stats(datadf, workstrokesonly=True, ignorehr=True,
|
||||
pass
|
||||
|
||||
try:
|
||||
mask = datadf['spm'] > 60
|
||||
mask = datadf['spm'] > 120
|
||||
datadf.mask(mask,inplace=True)
|
||||
except (KeyError,TypeError):
|
||||
pass
|
||||
@@ -2252,6 +2252,7 @@ def getsmallrowdata_db(columns, ids=[], doclean=True,workstrokesonly=True,comput
|
||||
else:
|
||||
try:
|
||||
df = pd.read_parquet(csvfilenames[0],columns=columns)
|
||||
for c in columns:
|
||||
except (OSError,ArrowInvalid):
|
||||
rowdata,row = getrowdata(id=ids[0])
|
||||
if rowdata and len(rowdata.df):
|
||||
|
||||
Reference in New Issue
Block a user