Skip to content
Snippets Groups Projects
Commit 7b6df422 authored by leufen1's avatar leufen1
Browse files

update data handler single station

parent 50d5c130
No related branches found
No related tags found
3 merge requests!522filter can now combine obs, forecast, and apriori for first iteration. Further...,!521Resolve "release v2.4.0",!517Resolve "load ifs data"
Pipeline #143738 passed
...@@ -300,7 +300,7 @@ class DataHandlerSingleStation(AbstractDataHandler): ...@@ -300,7 +300,7 @@ class DataHandlerSingleStation(AbstractDataHandler):
self._data, self.input_data, self.target_data = list(map(f_prep, [_data, _input_data, _target_data])) self._data, self.input_data, self.target_data = list(map(f_prep, [_data, _input_data, _target_data]))
def make_input_target(self): def make_input_target(self):
vars = [self.variables, self.target_var] vars = [*self.variables, self.target_var]
stats_per_var = helpers.select_from_dict(self.statistics_per_var, vars) stats_per_var = helpers.select_from_dict(self.statistics_per_var, vars)
data_origin = helpers.select_from_dict(self.data_origin, vars) data_origin = helpers.select_from_dict(self.data_origin, vars)
data, self.meta = self.load_data(self.path, self.station, stats_per_var, self.sampling, data, self.meta = self.load_data(self.path, self.station, stats_per_var, self.sampling,
......
...@@ -196,7 +196,6 @@ def extract_timeseries_data(result, result_format): ...@@ -196,7 +196,6 @@ def extract_timeseries_data(result, result_format):
def load_station_information(station_name: List[str], url_base: str, headers: Dict): def load_station_information(station_name: List[str], url_base: str, headers: Dict):
# opts = {"base": url_base, "service": f"stationmeta/{station_name[0]}"}
opts = {"base": url_base, "service": f"stationmeta", "param_id": station_name[0]} opts = {"base": url_base, "service": f"stationmeta", "param_id": station_name[0]}
return get_data(opts, headers) return get_data(opts, headers)
......
...@@ -28,13 +28,14 @@ class TestPreProcessing: ...@@ -28,13 +28,14 @@ class TestPreProcessing:
@pytest.fixture @pytest.fixture
def obj_with_exp_setup(self): def obj_with_exp_setup(self):
with RunEnvironment():
ExperimentSetup(stations=['DEBW107', 'DEBW013', 'DEBW087', 'DEBW99X'], ExperimentSetup(stations=['DEBW107', 'DEBW013', 'DEBW087', 'DEBW99X'],
statistics_per_var={'o3': 'dma8eu', 'temp': 'maximum'}, station_type="background", statistics_per_var={'o3': 'dma8eu', 'temp': 'maximum'}, station_type="background",
data_origin={'o3': 'UBA', 'temp': 'UBA'}, data_handler=DefaultDataHandler) data_origin={'o3': 'UBA', 'temp': 'UBA'}, data_handler=DefaultDataHandler)
pre = object.__new__(PreProcessing) pre = object.__new__(PreProcessing)
super(PreProcessing, pre).__init__() super(PreProcessing, pre).__init__()
yield pre yield pre
RunEnvironment().__del__() # RunEnvironment().__del__()
def test_init(self, caplog): def test_init(self, caplog):
ExperimentSetup(stations=['DEBW107', 'DEBW013', 'DEBW087'], ExperimentSetup(stations=['DEBW107', 'DEBW013', 'DEBW087'],
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment