@@ -45,8 +45,8 @@ def query_csv(self, query: str, org=None, dialect: Dialect = default_dialect, pa
45
45
"""
46
46
if org is None :
47
47
org = self ._influxdb_client .org
48
- response = self ._query_api .post_query (org = org , query = self ._create_query (query , dialect , params ), async_req = False ,
49
- _preload_content = False )
48
+ response = self ._query_api .post_query (org = org , query = self ._create_query (query , dialect , params ),
49
+ async_req = False , _preload_content = False )
50
50
51
51
return csv .reader (codecs .iterdecode (response , 'utf-8' ))
52
52
@@ -67,7 +67,7 @@ def query_raw(self, query: str, org=None, dialect=default_dialect, params: dict
67
67
68
68
return result
69
69
70
- def query (self , query : str , org = None , params : dict = None ) -> List ['FluxTable' ]:
70
+ def query (self , query : str , org = None , params : dict = None ) -> List ['FluxTable' ]:
71
71
"""
72
72
Execute synchronous Flux query and return result as a List['FluxTable'].
73
73
@@ -201,7 +201,7 @@ def _build_flux_ast(params: dict = None):
201
201
if params is None :
202
202
return None
203
203
204
- return File (package = None , name = None , type = None , imports = [], body = QueryApi ._params_to_extern_ast (params ))
204
+ return File (package = None , name = None , type = None , imports = [], body = QueryApi ._params_to_extern_ast (params ))
205
205
206
206
def __del__ (self ):
207
207
"""Close QueryAPI."""
0 commit comments