Skip to content

Commit ffd1af9

Browse files
author
Panos
committed
Fix chunked and chunk size parameter set
1 parent 7dddb0b commit ffd1af9

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

influxdb/client.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -349,6 +349,11 @@ def query(self,
349349
if epoch is not None:
350350
params['epoch'] = epoch
351351

352+
if chunked:
353+
params['chunked'] = 'true'
354+
if chunk_size > 0:
355+
params['chunk_size'] = chunk_size
356+
352357
response = self.request(
353358
url="query",
354359
method='GET',
@@ -357,10 +362,7 @@ def query(self,
357362
expected_response_code=expected_response_code
358363
)
359364

360-
if chunked or 'chunked' in params:
361-
params['chunked'] = 'true'
362-
if chunk_size > 0:
363-
params['chunk_size'] = chunk_size
365+
if chunked:
364366
return self._read_chunked_response(response)
365367

366368
data = response.json()

0 commit comments

Comments
 (0)