Insert missing years for temporal stats on wind and pv

rl-institut · Apr 25, 2024 · 9e28a22 · 9e28a22
1 parent a0d87e4
commit 9e28a22
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 0 deletions.
diff --git a/apipe/store/datasets/bnetza_mastr_pv_ground_region/create.smk b/apipe/store/datasets/bnetza_mastr_pv_ground_region/create.smk
@@ -103,5 +103,10 @@ rule create_development_over_time:
         df_combined["capacity_net"] = (
             df_combined["capacity_net"].div(1e3).round(1)
         )
+        # Fill missing years by using values from year before
+        df_combined = df_combined.set_index("year").reindex(
+            range(df_combined["year"].min(), df_combined["year"].max() + 1)
+        ).ffill().reset_index()
+
         df_combined["year"] = df_combined["year"].astype(int)
         df_combined.to_csv(output[0], index=False)
diff --git a/apipe/store/datasets/bnetza_mastr_pv_roof_region/create.smk b/apipe/store/datasets/bnetza_mastr_pv_roof_region/create.smk
@@ -101,5 +101,10 @@ rule create_development_over_time:
         df_combined["capacity_net"] = (
             df_combined["capacity_net"].div(1e3).round(1)
         )
+        # Fill missing years by using values from year before
+        df_combined = df_combined.set_index("year").reindex(
+            range(df_combined["year"].min(), df_combined["year"].max() + 1)
+        ).ffill().reset_index()
+
         df_combined["year"] = df_combined["year"].astype(int)
         df_combined.to_csv(output[0], index=False)
diff --git a/apipe/store/datasets/bnetza_mastr_wind_region/create.smk b/apipe/store/datasets/bnetza_mastr_wind_region/create.smk
@@ -94,5 +94,10 @@ rule create_development_over_time:
         df_combined["capacity_net"] = (
             df_combined["capacity_net"].div(1e3).round(1)
         )
+        # Fill missing years by using values from year before
+        df_combined = df_combined.set_index("year").reindex(
+            range(df_combined["year"].min(), df_combined["year"].max() + 1)
+        ).ffill().reset_index()
+
         df_combined["year"] = df_combined["year"].astype(int)
         df_combined.to_csv(output[0], index=False)