diff --git a/apipe/store/datasets/bnetza_mastr_pv_ground_region/create.smk b/apipe/store/datasets/bnetza_mastr_pv_ground_region/create.smk index 3def521..b5073af 100644 --- 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 index 1fb3e6a..64b4349 100644 --- 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 index f556809..725606c 100644 --- 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)