Skip to content

Commit d7fa6c4

Browse files
flake issues
1 parent 79586f1 commit d7fa6c4

File tree

4 files changed

+23
-23
lines changed

4 files changed

+23
-23
lines changed

pygeoapi/api/__init__.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1510,6 +1510,7 @@ def validate_bbox(value=None) -> list:
15101510

15111511
return bbox
15121512

1513+
15131514
def validate_filter_dims(query_string):
15141515
if not isinstance(query_string, str):
15151516
msg = 'dimension query must be string'

pygeoapi/openapi.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -609,7 +609,7 @@ def get_oas_30_parameters(cfg: dict, locale_: str):
609609
'type': 'string'
610610
}
611611
},
612-
'dims':{
612+
'dims': {
613613
'name': 'dims',
614614
'in': 'query',
615615
'description': 'Allows to select dims from multi dimensional EDR',

pygeoapi/provider/xarray_.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -144,10 +144,8 @@ def get_dims(self):
144144
'x-ogc-unit': value.attrs.get('units'),
145145
'values': value.values.tolist()
146146
}
147-
148147
return self._dims
149148

150-
151149
def query(self, properties=[], subsets={}, bbox=[], bbox_crs=4326,
152150
datetime_=None, format_='json', **kwargs):
153151
"""

pygeoapi/provider/xarray_edr.py

Lines changed: 21 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -129,11 +129,11 @@ def position(self, **kwargs):
129129
else:
130130
query_params[coord] = self._dims[coord]['type'](level)
131131
else:
132-
raise ProviderInvalidQueryError(user_msg = f"""Invalid Value '{level}' for Dimension Parameter '{coord}'. Valid Values are '{self._dims[coord]['values']}'""")
132+
raise ProviderInvalidQueryError(user_msg=f"""Invalid Value '{level}' for Dimension Parameter '{coord}'. Valid Values are '{self._dims[coord]['values']}'""")
133133

134134
data = data.sel(string_query)
135135
else:
136-
raise ProviderInvalidQueryError(user_msg = f"""Invalid Dimension Parameter '{coord}'""")
136+
raise ProviderInvalidQueryError(user_msg=f"""Invalid Dimension Parameter '{coord}'""")
137137

138138
LOGGER.debug(query_params)
139139

@@ -229,31 +229,32 @@ def cube(self, **kwargs):
229229

230230
dims = kwargs.get('dims')
231231

232-
if dims:
233-
string_query = {}
234-
if isinstance(dims, dict):
235-
for coord, level in dims.items():
236-
if coord in self._dims:
237-
if self._dims[coord]['type'](level) in self._dims[coord]['values']:
238-
if self._dims[coord]['type'] == str:
239-
string_query[coord] = self._dims[coord]['type'](level)
240-
else:
241-
query_params[coord] = self._dims[coord]['type'](level)
242-
else:
243-
raise ProviderInvalidQueryError(
244-
user_msg=f"""Invalid Value '{level}' for Dimension Parameter '{coord}'. Valid Values are '{self._dims[coord]['values']}'""")
245-
246-
data = data.sel(string_query)
247-
else:
248-
raise ProviderInvalidQueryError(user_msg=f"""Invalid Dimension Parameter '{coord}'""")
249-
250232
LOGGER.debug(f'query parameters: {query_params}')
251233
try:
252234
if select_properties:
253235
self._fields = {k: v for k, v in self._fields.items() if k in select_properties} # noqa
254236
data = self._data[[*select_properties]]
255237
else:
256238
data = self._data
239+
240+
if dims:
241+
string_query = {}
242+
if isinstance(dims, dict):
243+
for coord, level in dims.items():
244+
if coord in self._dims:
245+
if self._dims[coord]['type'](level) in self._dims[coord]['values']:
246+
if self._dims[coord]['type'] == str:
247+
string_query[coord] = self._dims[coord]['type'](level)
248+
else:
249+
query_params[coord] = self._dims[coord]['type'](level)
250+
else:
251+
raise ProviderInvalidQueryError(
252+
user_msg=f"""Invalid Value '{level}' for Dimension Parameter '{coord}'. Valid Values are '{self._dims[coord]['values']}'""")
253+
254+
data = data.sel(string_query)
255+
else:
256+
raise ProviderInvalidQueryError(user_msg=f"""Invalid Dimension Parameter '{coord}'""")
257+
257258
data = data.sel(query_params)
258259
data = _convert_float32_to_float64(data)
259260
except KeyError:

0 commit comments

Comments
 (0)