@@ -52,13 +52,13 @@ def _preprocess(idx: int, **kwargs):
5252 vars .update ({var : (ds [var ].dims , ds [var ].data )})
5353
5454 for var in md_vars :
55- vars .update ({var : (("storm" ,), np . array ( [ds [var ].data ]) )})
55+ vars .update ({var : (("storm" ,), [ds [var ].data ])})
5656
5757 return xr .Dataset (
5858 vars ,
5959 {
6060 "id" : (("storm" ,), np .array ([idx ])),
61- "time" : (("date_time " ,), np . array ( ds ["time" ].data ) ),
61+ "time" : (("obs " ,), ds ["time" ].data ),
6262 },
6363 )
6464 else :
@@ -86,6 +86,7 @@ def to_raggedarray(
8686 download_with_progress ([(src_url , dst_path , None )])
8787
8888 ds = xr .open_dataset (dst_path , engine = "netcdf4" )
89+ ds = ds .rename_dims ({"date_time" : "obs" })
8990
9091 data_vars = list ()
9192 md_vars = list ()
@@ -98,7 +99,7 @@ def to_raggedarray(
9899 var : xr .DataArray = ds [var_name ]
99100
100101 # Avoid loading the data variables that also utilize the quadrant dimension for now
101- if "date_time " in var .dims and len (var .dims ) = = 2 :
102+ if "obs " in var .dims and len (var .dims ) > = 2 :
102103 data_vars .append (var_name )
103104 elif len (var .dims ) == 1 and var .dims [0 ] == "storm" :
104105 md_vars .append (var_name )
@@ -108,7 +109,7 @@ def to_raggedarray(
108109 name_coords = ["id" , "time" ],
109110 name_meta = md_vars ,
110111 name_data = data_vars ,
111- name_dims = {"storm" : "rows" , "obs" : "obs" },
112+ name_dims = {"storm" : "rows" , "obs" : "obs" , "quadrant" : "quadrant" },
112113 rowsize_func = _rowsize ,
113114 preprocess_func = _preprocess ,
114115 attrs_global = ds .attrs ,
0 commit comments