Dendro

level1/do_dendro_calculation.py

@@ -102,6 +102,9 @@ def dendroProcess(data, manflags):
         first_value = values.iloc[0] 
         start_idx = concat_df['d_ini'].dropna().index
         stop_idx = start_idx[1:].tolist() + [pd.Timestamp.today()]
+        # some old data doesn't have useable manflags, this should be filtered here
+        if start_idx.empty:
+            continue
 
         temporary = []
         for start, stop in zip(start_idx, stop_idx):
@@ -111,10 +114,10 @@ def dendroProcess(data, manflags):
             calc = dendroCalculation(chunk, key, first_value)
             temporary.append(calc)
 
-        name = f"bhd_auto_{int(key.split('_')[1])}"
+        name = f"{int(key.split('_')[1])}"
 
         # data column
-        temporary_series = pd.concat(temporary, axis=0).rename(f"{name} [mm]")
+        temporary_series = pd.concat(temporary, axis=0).rename(f"bhd_auto_{name} [mm]")
         final.append(temporary_series)
 
         # interpolation column
@@ -123,7 +126,7 @@ def dendroProcess(data, manflags):
         final.append(df_reindexed * 10)
 
         # flags column
-        flags = pd.Series(9, index=temporary_series.index, name=f"{name}_f")
+        flags = pd.Series(9, index=temporary_series.index, name=f"bhd_{name}_f")
         final.append(flags)
 
     final_df = pd.concat(final, axis=1)