@@ -48,21 +48,24 @@ def fetch_data():
4848 data_df = load_pv_gsp_raw_data_from_pvlive (start = start , end = end , normalize_data = False )
4949
5050 # pivot to index as datetime_gmt, and columns as gsp_id
51- data_generation_df = data_df .pivot (index = "datetime_gmt" , columns = "gsp_id" , values = "generation_mw" )
52- data_installedcapacity_df = data_df .pivot (index = "datetime_gmt" , columns = "gsp_id" , values = "installedcapacity_mwp" )
51+ data_generation_df = data_df .pivot (
52+ index = "datetime_gmt" , columns = "gsp_id" , values = "generation_mw"
53+ )
54+ data_installedcapacity_df = data_df .pivot (
55+ index = "datetime_gmt" , columns = "gsp_id" , values = "installedcapacity_mwp"
56+ )
5357 data_capacity_df = data_df .pivot (index = "datetime_gmt" , columns = "gsp_id" , values = "capacity_mwp" )
54- data_updated_gmt_df = data_df .pivot (index = "datetime_gmt" , columns = "gsp_id" , values = "updated_gmt" )
58+ data_updated_gmt_df = data_df .pivot (
59+ index = "datetime_gmt" , columns = "gsp_id" , values = "updated_gmt"
60+ )
5561 data_xarray = xr .Dataset (
5662 data_vars = {
5763 "generation_mw" : (("datetime_gmt" , "gsp_id" ), data_generation_df ),
5864 "installedcapacity_mwp" : (("datetime_gmt" , "gsp_id" ), data_installedcapacity_df ),
5965 "capacity_mwp" : (("datetime_gmt" , "gsp_id" ), data_capacity_df ),
6066 "updated_gmt" : (("datetime_gmt" , "gsp_id" ), data_updated_gmt_df ),
6167 },
62- coords = {
63- "datetime_gmt" : data_generation_df .index ,
64- "gsp_id" : data_generation_df .columns
65- },
68+ coords = {"datetime_gmt" : data_generation_df .index , "gsp_id" : data_generation_df .columns },
6669 )
6770
6871 # save config to file
@@ -71,7 +74,8 @@ def fetch_data():
7174
7275 # Make encoding
7376 encoding = {
74- var : {"compressor" : numcodecs .Blosc (cname = "zstd" , clevel = 5 )} for var in data_xarray .data_vars
77+ var : {"compressor" : numcodecs .Blosc (cname = "zstd" , clevel = 5 )}
78+ for var in data_xarray .data_vars
7579 }
7680
7781 # save data to file
0 commit comments