Private
Public Access
1
0

adding error checking

This commit is contained in:
Sander Roosendaal
2021-05-24 21:58:31 +02:00
parent 5437ff6e2f
commit 37a063950f
3 changed files with 2 additions and 2 deletions

View File

@@ -1286,7 +1286,7 @@ def update_wps(r,types,mode='water',asynchron=True):
try: try:
mask = df['driveenergy'] > 100 mask = df['driveenergy'] > 100
except KeyError: except (KeyError, TypeError):
return False return False
wps_median = int(df.loc[mask,'driveenergy'].median()) wps_median = int(df.loc[mask,'driveenergy'].median())

View File

@@ -2802,7 +2802,7 @@ def handle_update_wps(rid,types,ids,mode,debug=False,**kwargs):
df = getsmallrowdata_db(['time','driveenergy'],ids=ids) df = getsmallrowdata_db(['time','driveenergy'],ids=ids)
try: try:
mask = df['driveenergy'] > 100 mask = df['driveenergy'] > 100
except KeyError: except (KeyError, TypeError):
return 0 return 0
wps_median = int(df.loc[mask,'driveenergy'].median()) wps_median = int(df.loc[mask,'driveenergy'].median())

Binary file not shown.