@@ -176,24 +176,12 @@ def get_qwdata(
176176 """
177177 _check_sites_value_types (sites )
178178
179+ kwargs ['site_no' ] = kwargs .pop ('site_no' , sites )
180+ kwargs ['begin_date' ] = kwargs .pop ('begin_date' , start )
181+ kwargs ['end_date' ] = kwargs .pop ('end_date' , end )
182+ kwargs ['multi_index' ] = multi_index
179183 if wide_format :
180184 kwargs ['qw_sample_wide' ] = 'qw_sample_wide'
181- start = kwargs .pop ('begin_date' , start )
182- end = kwargs .pop ('end_date' , end )
183- sites = kwargs .pop ('site_no' , sites )
184- return _qwdata (
185- site_no = sites ,
186- begin_date = start ,
187- end_date = end ,
188- datetime_index = datetime_index ,
189- multi_index = multi_index ,
190- ssl_check = ssl_check ,
191- ** kwargs ,
192- )
193-
194-
195- def _qwdata (datetime_index = True , ssl_check = True , ** kwargs ):
196- # check number of sites, may need to create multiindex
197185
198186 payload = {
199187 'agency_cd' : 'USGS' ,
@@ -207,7 +195,6 @@ def _qwdata(datetime_index=True, ssl_check=True, **kwargs):
207195 'rdb_compression' : 'value' ,
208196 'submitted_form' : 'brief_list' ,
209197 }
210- # 'qw_sample_wide': 'separated_wide'}
211198
212199 # check for parameter codes, and reformat query args
213200 qwdata_parameter_code_field = 'parameterCd'
@@ -224,9 +211,7 @@ def _qwdata(datetime_index=True, ssl_check=True, **kwargs):
224211 )
225212 else :
226213 kwargs ['list_of_search_criteria' ] = 'multiple_parameter_cds'
227- # search_criteria = kwargs.get('list_of_search_criteria
228214
229- # kwargs = {**payload, **kwargs}
230215 kwargs .update (payload )
231216
232217 warnings .warn (
@@ -296,15 +281,10 @@ def get_discharge_measurements(
296281 """
297282 _check_sites_value_types (sites )
298283
299- start = kwargs .pop ('begin_date' , start )
300- end = kwargs .pop ('end_date' , end )
301- sites = kwargs .pop ('site_no' , sites )
302- return _discharge_measurements (
303- site_no = sites , begin_date = start , end_date = end , ssl_check = ssl_check , ** kwargs
304- )
305-
284+ kwargs ['site_no' ] = kwargs .pop ('site_no' , sites )
285+ kwargs ['begin_date' ] = kwargs .pop ('begin_date' , start )
286+ kwargs ['end_date' ] = kwargs .pop ('end_date' , end )
306287
307- def _discharge_measurements (ssl_check = True , ** kwargs ):
308288 response = query_waterdata (
309289 'measurements' , format = 'rdb' , ssl_check = ssl_check , ** kwargs
310290 )
@@ -366,20 +346,11 @@ def get_discharge_peaks(
366346 """
367347 _check_sites_value_types (sites )
368348
369- start = kwargs .pop ('begin_date' , start )
370- end = kwargs .pop ('end_date' , end )
371- sites = kwargs .pop ('site_no' , sites )
372- return _discharge_peaks (
373- site_no = sites ,
374- begin_date = start ,
375- end_date = end ,
376- multi_index = multi_index ,
377- ssl_check = ssl_check ,
378- ** kwargs ,
379- )
380-
349+ kwargs ['site_no' ] = kwargs .pop ('site_no' , sites )
350+ kwargs ['begin_date' ] = kwargs .pop ('begin_date' , start )
351+ kwargs ['end_date' ] = kwargs .pop ('end_date' , end )
352+ kwargs ['multi_index' ] = multi_index
381353
382- def _discharge_peaks (ssl_check = True , ** kwargs ):
383354 response = query_waterdata ('peaks' , format = 'rdb' , ssl_check = ssl_check , ** kwargs )
384355
385356 df = _read_rdb (response .text )
@@ -440,21 +411,11 @@ def get_gwlevels(
440411 """
441412 _check_sites_value_types (sites )
442413
443- start = kwargs .pop ('startDT' , start )
444- end = kwargs .pop ('endDT' , end )
445- sites = kwargs .pop ('sites' , sites )
446- return _gwlevels (
447- startDT = start ,
448- endDT = end ,
449- datetime_index = datetime_index ,
450- sites = sites ,
451- multi_index = multi_index ,
452- ssl_check = ssl_check ,
453- ** kwargs ,
454- )
455-
414+ kwargs ['startDT' ] = kwargs .pop ('startDT' , start )
415+ kwargs ['endDT' ] = kwargs .pop ('endDT' , end )
416+ kwargs ['sites' ] = kwargs .pop ('sites' , sites )
417+ kwargs ['multi_index' ] = multi_index
456418
457- def _gwlevels (datetime_index = True , ssl_check = True , ** kwargs ):
458419 response = query_waterservices ('gwlevels' , ssl_check = ssl_check , ** kwargs )
459420
460421 df = _read_rdb (response .text )
@@ -691,20 +652,11 @@ def get_dv(
691652 """
692653 _check_sites_value_types (sites )
693654
694- start = kwargs .pop ('startDT' , start )
695- end = kwargs .pop ('endDT' , end )
696- sites = kwargs .pop ('sites' , sites )
697- return _dv (
698- startDT = start ,
699- endDT = end ,
700- sites = sites ,
701- multi_index = multi_index ,
702- ssl_check = ssl_check ,
703- ** kwargs ,
704- )
705-
655+ kwargs ['startDT' ] = kwargs .pop ('startDT' , start )
656+ kwargs ['endDT' ] = kwargs .pop ('endDT' , end )
657+ kwargs ['sites' ] = kwargs .pop ('sites' , sites )
658+ kwargs ['multi_index' ] = multi_index
706659
707- def _dv (ssl_check = True , ** kwargs ):
708660 response = query_waterservices ('dv' , format = 'json' , ssl_check = ssl_check , ** kwargs )
709661 df = _read_json (response .json ())
710662
@@ -873,21 +825,14 @@ def get_iv(
873825 """
874826 _check_sites_value_types (sites )
875827
876- start = kwargs .pop ('startDT' , start )
877- end = kwargs .pop ('endDT' , end )
878- sites = kwargs .pop ('sites' , sites )
879- return _iv (
880- startDT = start ,
881- endDT = end ,
882- sites = sites ,
883- multi_index = multi_index ,
884- ssl_check = ssl_check ,
885- ** kwargs ,
886- )
887-
828+ kwargs ['startDT' ] = kwargs .pop ('startDT' , start )
829+ kwargs ['endDT' ] = kwargs .pop ('endDT' , end )
830+ kwargs ['sites' ] = kwargs .pop ('sites' , sites )
831+ kwargs ['multi_index' ] = multi_index
888832
889- def _iv (ssl_check = True , ** kwargs ):
890- response = query_waterservices ('iv' , format = 'json' , ssl_check = ssl_check , ** kwargs )
833+ response = query_waterservices (
834+ service = 'iv' , format = 'json' , ssl_check = ssl_check , ** kwargs
835+ )
891836 df = _read_json (response .json ())
892837 return format_response (df , ** kwargs ), NWIS_Metadata (response , ** kwargs )
893838
@@ -1089,10 +1034,7 @@ def get_ratings(
10891034
10901035 """
10911036 site = kwargs .pop ('site_no' , site )
1092- return _ratings (site = site , file_type = file_type , ssl_check = ssl_check )
1093-
10941037
1095- def _ratings (site , file_type , ssl_check = True ):
10961038 payload = {}
10971039 url = WATERDATA_BASE_URL + 'nwisweb/get_ratings/'
10981040 if site is not None :
0 commit comments