@@ -50,10 +50,6 @@ def _lock_file_read(self, array):
5050
5151 return array
5252
53- def subarray_parameters (self ):
54- """TODOUGRID"""
55- raise NotImplementedError ("TODOUGRID" )
56-
5753 def to_dask_array (self , chunks = "auto" ):
5854 """Convert the data to a `dask` array.
5955
@@ -92,8 +88,7 @@ def to_dask_array(self, chunks="auto"):
9288
9389 context = partial (config .set , scheduler = "synchronous" )
9490
95- compressed_dimensions = self .compressed_dimensions ()
96- conformed_data = self .conformed_data ()
91+ # compressed_dimensions = self.compressed_dimensions() TODOUGRID
9792
9893 # If possible, convert the compressed data to a dask array
9994 # that doesn't support concurrent reads. This prevents
@@ -103,12 +98,10 @@ def to_dask_array(self, chunks="auto"):
10398 # TODO: This won't be necessary if this is refactored so that
10499 # the compressed data is part of the same dask graph as
105100 # the compressed subarrays.
101+ conformed_data = self .conformed_data ()
106102 conformed_data = {
107103 k : self ._lock_file_read (v ) for k , v in conformed_data .items ()
108104 }
109-
110- # TODO: When the minimum version is Python 3.9, replace with
111- # `subarray_kwargs = conformed_data | self.subarray_parameters()`
112105 subarray_kwargs = {** conformed_data , ** self .subarray_parameters ()}
113106
114107 # Get the (cfdm) subarray class
@@ -129,14 +122,13 @@ def to_dask_array(self, chunks="auto"):
129122 subarray = Subarray (
130123 indices = c_indices ,
131124 shape = u_shape ,
132- compressed_dimensions = compressed_dimensions ,
125+ # compressed_dimensions=compressed_dimensions, # TODOUGRID
133126 context_manager = context ,
134127 ** subarray_kwargs ,
135128 )
136129
137130 key = f"{ subarray_name } -{ tokenize (subarray )} "
138131 dsk [key ] = subarray
139-
140132 dsk [name + chunk_location ] = (getter , key , Ellipsis , False , False )
141133
142134 # Return the dask array
0 commit comments