Skip to content
Snippets Groups Projects
Commit 104c321f authored by leufen1's avatar leufen1
Browse files

some minor fixes, apply bug fix from #212, another minor bug fixed inside the...

some minor fixes, apply bug fix from #212, another minor bug fixed inside the mixed sampling data handler regarding parameters start and stop
parent 6462795c
No related branches found
No related tags found
3 merge requests!192include Develop,!191Resolve "release v1.1.0",!186Resolve "Separation of Scales"
Pipeline #51985 passed
...@@ -37,7 +37,7 @@ class DataHandlerMixedSamplingSingleStation(DataHandlerSingleStation): ...@@ -37,7 +37,7 @@ class DataHandlerMixedSamplingSingleStation(DataHandlerSingleStation):
def load_and_interpolate(self, ind) -> [xr.DataArray, pd.DataFrame]: def load_and_interpolate(self, ind) -> [xr.DataArray, pd.DataFrame]:
data, self.meta = self.load_data(self.path[ind], self.station, self.statistics_per_var, self.sampling[ind], data, self.meta = self.load_data(self.path[ind], self.station, self.statistics_per_var, self.sampling[ind],
self.station_type, self.network, self.store_data_locally, start, end) self.station_type, self.network, self.store_data_locally, self.start, self.end)
data = self.interpolate(data, dim=self.time_dim, method=self.interpolation_method, data = self.interpolate(data, dim=self.time_dim, method=self.interpolation_method,
limit=self.interpolation_limit) limit=self.interpolation_limit)
return data return data
......
...@@ -46,7 +46,7 @@ def download_join(station_name: Union[str, List[str]], stat_var: dict, station_t ...@@ -46,7 +46,7 @@ def download_join(station_name: Union[str, List[str]], stat_var: dict, station_t
# correct stat_var values if data is not aggregated (hourly) # correct stat_var values if data is not aggregated (hourly)
if sampling == "hourly": if sampling == "hourly":
[stat_var.update({k: "values"}) for k in stat_var.keys()] stat_var = {key: "values" for key in stat_var.keys()}
# download all variables with given statistic # download all variables with given statistic
data = None data = None
......
...@@ -207,6 +207,7 @@ class PreProcessing(RunEnvironment): ...@@ -207,6 +207,7 @@ class PreProcessing(RunEnvironment):
logging.info(f"check valid stations started{' (%s)' % (set_name if set_name is not None else 'all')}") logging.info(f"check valid stations started{' (%s)' % (set_name if set_name is not None else 'all')}")
# calculate transformation using train data # calculate transformation using train data
if set_name == "train": if set_name == "train":
logging.info("setup transformation using train data exclusively")
self.transformation(data_handler, set_stations) self.transformation(data_handler, set_stations)
# start station check # start station check
collection = DataCollection() collection = DataCollection()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment