11"""Query data in InfluxDB 3."""
22import asyncio
3- import concurrent .futures
43# coding: utf-8
54import json
65
@@ -163,7 +162,6 @@ def query(self, query: str, language: str, mode: str, database: str, **kwargs):
163162 It should be a ``dictionary`` of key-value pairs.
164163 :return: The query result in the specified mode.
165164 """
166- from influxdb_client_3 import polars as has_polars
167165 try :
168166 ticket , _options = self ._prepare_query (query , language , database , ** kwargs )
169167
@@ -178,12 +176,11 @@ async def query_async(self, query: str, language: str, mode: str, database: str,
178176 ticket , options = self ._prepare_query (query , language , database , ** kwargs )
179177 loop = asyncio .get_running_loop ()
180178 _flight_reader = await loop .run_in_executor (None ,
181- self ._flight_client .do_get , ticket , options )
179+ self ._flight_client .do_get , ticket , options )
182180 return await loop .run_in_executor (None , self ._translate_stream_reader ,
183181 _flight_reader ,
184182 mode )
185183 except Exception as e :
186- print (f"\DEBUG caught exception e { e } " )
187184 raise e
188185
189186 def _translate_stream_reader (self , reader : FlightStreamReader , mode : str ):
0 commit comments