Skip to content
Snippets Groups Projects
Commit 39751ae2 authored by lukas leufen's avatar lukas leufen
Browse files

moved get_X_original to DataHandlerFilter

parent 136a01f1
No related branches found
No related tags found
4 merge requests!430update recent developments,!413update release branch,!412Resolve "release v2.0.0",!405Lukas issue370 feat make use filter branches available for all dh with filters
Pipeline #94332 passed
......@@ -283,21 +283,6 @@ class DataHandlerMixedSamplingWithClimateFirFilter(DataHandlerClimateFirFilter):
dh_transformation=dh_transformation[1], **kwargs)
return {"filtered": transformation_filtered, "unfiltered": transformation_unfiltered}
def get_X_original(self):
if self.use_filter_branches is True:
X = []
for data in self._collection:
if hasattr(data, "filter_dim"):
X_total = data.get_X()
filter_dim = data.filter_dim
for filter_name in data.filter_dim_order:
X.append(X_total.sel({filter_dim: filter_name}, drop=True))
else:
X.append(data.get_X())
return X
else:
return super().get_X_original()
class DataHandlerMixedSamplingWithClimateAndFirFilter(DataHandlerMixedSamplingWithClimateFirFilter):
# data_handler = DataHandlerMixedSamplingWithClimateFirFilterSingleStation
......@@ -457,18 +442,3 @@ class DataHandlerMixedSamplingWithClimateAndFirFilter(DataHandlerMixedSamplingWi
else: # if no unfiltered meteo branch
transformation_res["filtered_meteo"] = transformation_meteo
return transformation_res if len(transformation_res) > 0 else None
def get_X_original(self):
if self.use_filter_branches is True:
X = []
for data in self._collection:
if hasattr(data, "filter_dim"):
X_total = data.get_X()
filter_dim = data.filter_dim
for filter_name in data.filter_dim_order:
X.append(X_total.sel({filter_dim: filter_name}, drop=True))
else:
X.append(data.get_X())
return X
else:
return super().get_X_original()
......@@ -116,6 +116,21 @@ class DataHandlerFilter(DefaultDataHandler):
self.use_filter_branches = use_filter_branches
super().__init__(*args, **kwargs)
def get_X_original(self):
if self.use_filter_branches is True:
X = []
for data in self._collection:
if hasattr(data, "filter_dim"):
X_total = data.get_X()
filter_dim = data.filter_dim
for filter_name in data.filter_dim_order:
X.append(X_total.sel({filter_dim: filter_name}, drop=True))
else:
X.append(data.get_X())
return X
else:
return super().get_X_original()
class DataHandlerFirFilterSingleStation(DataHandlerFilterSingleStation):
"""Data handler for a single station to be used by a superior data handler. Inputs are FIR filtered."""
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment