Skip to content
Snippets Groups Projects
Commit 52b88746 authored by Peter Lünenschloß's avatar Peter Lünenschloß
Browse files

fixed way harm funcs reassign harmed/deharmed flags

parent dc1c72b0
No related branches found
No related tags found
4 merge requests!193Release 1.4,!188Release 1.4,!49Dataprocessing features,!44Dataprocessing features
Pipeline #3616 passed with stage
in 7 minutes and 37 seconds
......@@ -39,6 +39,7 @@ def proc_interpolateMissing(data, field, flagger, method, inter_order=2, inter_l
@register()
def proc_resample(data, field, flagger, freq, func="mean", max_invalid_total=None, max_invalid_consec=None,
flag_agg_func='max', **kwargs):
data = data.copy()
datcol = data[field]
# filter data for invalid patterns
......@@ -73,15 +74,14 @@ def proc_resample(data, field, flagger, freq, func="mean", max_invalid_total=Non
# data/flags reshaping:
data[field] = datcol
all_flags = flagger.getFlags()
all_flags[field] = datflags
flagger = flagger.initFlags(flags=all_flags)
reshape_flagger = flagger.initFlags(datcol).setFlags(field, flag=datflags, force=True, **kwargs)
flagger = flagger.getFlagger(drop=field).setFlagger(reshape_flagger)
return data, flagger
@register()
def proc_transform(data, field, flagger, func, **kwargs):
data = data.copy()
func = composeFunction(func)
data[field] = data[field].transform(func)
return data, flagger
\ No newline at end of file
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment