Skip to content
Snippets Groups Projects
Commit fa927cdb authored by Felix Kleinert's avatar Felix Kleinert
Browse files

logging for reindes

parent 039e47f5
No related branches found
No related tags found
2 merge requests!321Resolve "Apply TOAR Statistics on WRF-data handler",!259Draft: Resolve "WRF-Datahandler should inherit from SingleStationDatahandler"
Pipeline #75873 failed
...@@ -711,7 +711,12 @@ class SingleGridColumnWrfChemDataLoader(BaseWrfChemDataLoader): ...@@ -711,7 +711,12 @@ class SingleGridColumnWrfChemDataLoader(BaseWrfChemDataLoader):
def __toarstats_aggregation(self, data, local_time_zone, meta, target_sampling, var): def __toarstats_aggregation(self, data, local_time_zone, meta, target_sampling, var):
with TimeTracking(name=f"{self.station}: apply toarstats `{self.statistics_per_var[var]}({var})`"): with TimeTracking(name=f"{self.station}: apply toarstats `{self.statistics_per_var[var]}({var})`"):
spatial_dims = list(remove_items(data[var].dims, self.physical_t_coord_name)) spatial_dims = list(remove_items(data[var].dims, self.physical_t_coord_name))
try:
df = data[var].to_dataframe()[[var]].reset_index(level=spatial_dims)
except Exception as e:
logging.info(f"can't reset_index in __toarstats_aggregation: {e}")
df = data[var].to_dataframe()[[var]].reset_index(level=spatial_dims) df = data[var].to_dataframe()[[var]].reset_index(level=spatial_dims)
df = df[[var] + spatial_dims] df = df[[var] + spatial_dims]
df = self.set_external_time_zone_and_convert_to_local_time_zone(df, local_time_zone) df = self.set_external_time_zone_and_convert_to_local_time_zone(df, local_time_zone)
df = df.groupby(spatial_dims) df = df.groupby(spatial_dims)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment