@@ -271,8 +271,9 @@ def run_fe_reporting(rep: message_ix.Reporter, model: str, scenario: str):
271
271
py_df_all .filter (unit = "dimensionless" , keep = False )
272
272
.convert_unit ("GWa" , "EJ" )
273
273
.timeseries ()
274
+ .reset_index ()
274
275
)
275
- df_final .Unit = "EJ/yr"
276
+ df_final .unit = "EJ/yr"
276
277
return df_final
277
278
278
279
@@ -514,8 +515,9 @@ def run_fs_reporting(rep: message_ix.Reporter, model_name: str, scen_name: str):
514
515
py_df .filter (unit = "dimensionless" , keep = False )
515
516
.convert_unit ("GWa" , "EJ" )
516
517
.timeseries ()
518
+ .reset_index ()
517
519
)
518
- df_final .Unit = "EJ/yr"
520
+ df_final .unit = "EJ/yr"
519
521
return df_final
520
522
521
523
@@ -659,13 +661,16 @@ def run_all_categories(rep: message_ix.Reporter, model_name: str, scen_name: str
659
661
return dfs
660
662
661
663
662
- def run (scenario , upload_ts = False ):
664
+ def run (scenario , upload_ts = False , region = False ):
663
665
rep = Reporter .from_scenario (scenario )
664
666
665
667
dfs = run_all_categories (rep , scenario .model , scenario .scenario )
666
668
667
669
py_df = pyam .concat (dfs )
668
- py_df .aggregate_region (py_df .variable , append = True )
670
+ if region :
671
+ py_df .aggregate_region (py_df .variable , region = region , append = True )
672
+ else :
673
+ py_df .aggregate_region (py_df .variable , append = True )
669
674
py_df .filter (variable = "Share*" , keep = False , inplace = True )
670
675
if upload_ts :
671
676
scenario .add_timeseries (py_df .timeseries ())
0 commit comments