From 5739da52f54d10e98aef4fa45de96a8370bd56f8 Mon Sep 17 00:00:00 2001 From: Sander Roosendaal Date: Thu, 15 Sep 2022 21:54:59 +0200 Subject: [PATCH] fix --- rowers/alerts.py | 18 ++++++++++++++++-- rowers/dataroutines.py | 7 +++++-- 2 files changed, 21 insertions(+), 4 deletions(-) diff --git a/rowers/alerts.py b/rowers/alerts.py index e88dbcdf..5d8106c5 100644 --- a/rowers/alerts.py +++ b/rowers/alerts.py @@ -100,8 +100,22 @@ def alert_get_stats(alert, nperiod=0): # pragma: no cover boattype=alert.boattype) ids = [w.id for w in workouts] - df = getsmallrowdata_db(columns, ids=ids, doclean=True, - workstrokesonly=workstrokesonly) + try: + df = getsmallrowdata_db(columns, ids=ids, doclean=True, + workstrokesonly=workstrokesonly) + except: + return { + 'workouts': workouts.count(), + 'startdate': startdate, + 'enddate': enddate, + 'nr_strokes': 0, + 'nr_strokes_qualifying': 0, + 'percentage': 0, + 'nperiod': nperiod, + 'median': 0, + 'median_q': 0, + 'standard_dev': 0, + } if df.empty: return { diff --git a/rowers/dataroutines.py b/rowers/dataroutines.py index ead26e09..49fdb091 100644 --- a/rowers/dataroutines.py +++ b/rowers/dataroutines.py @@ -1246,8 +1246,11 @@ def getsmallrowdata_db(columns, ids=[], doclean=True, workstrokesonly=True, comp if rowdata and len(rowdata.df): _ = dataprep(rowdata.df, id=id, bands=True, otwpower=True, barchart=True) - df = pd.read_parquet(f, columns=columns) - data.append(df) + try: + df = pd.read_parquet(f, columns=columns) + data.append(df) + except (OSError, ArrowInvalid, IndexError): + pass try: df = pd.concat(data, axis=0)