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

Merge branch 'develop' into feature/fakturoid2

Browse Source
This commit is contained in:
Sander Roosendaal
2024-10-06 17:17:39 +02:00
parent aa5852839b c203d7cda1
commit 8ffbb0695f
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
rowers/dataroutines.py
View File

@@ -177,7 +177,11 @@ columndict = {
'cumdist': 'cum_dist', 'cumdist': 'cum_dist',
} }
def remove_nulls_pl(data): def remove_nulls_pl(data):
for c in data.columns:
if c=='hr':
dologging('remove_nulls.log',"HR data len {f}".format(f=len(data[c])))
data = data.lazy().with_columns( data = data.lazy().with_columns(
pl.when( pl.when(
pl.all().is_infinite() pl.all().is_infinite()
@@ -198,6 +202,10 @@ def remove_nulls_pl(data):
except: # pragma: no cover except: # pragma: no cover
pass pass
for c in data.columns:
if c=='hr':
dologging('remove_nulls.log',"HR data len {f}".format(f=len(data[c])))
return data return data
@@ -249,8 +257,7 @@ def get_video_data(w, groups=['basic'], mode='water'):
df2 = pd.concat([df2, coordinates], axis=1) df2 = pd.concat([df2, coordinates], axis=1)
latitude = df2['latitude'] latitude = df2['latitude']
longitude = df2['longitude'] longitude = df2['longitude']
boatspeed = (100*df2['velo'].fillna(method='ffill')).astype(int)/100. boatspeed = (100*df2['velo'].fillna(method='ffill').fillna(method='bfill')).astype(int)/100.
# bundle data # bundle data
data = { data = {
'boatspeed': boatspeed.values.tolist(), 'boatspeed': boatspeed.values.tolist(),