Skip to content

Commit

Permalink
chore: add explanatory note to CancelledError.
Browse files Browse the repository at this point in the history
  • Loading branch information
karel-rehor committed Nov 22, 2024
1 parent 012c50a commit 14bc332
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion influxdb_client/client/flux_csv_parser.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
"""Parsing response from InfluxDB to FluxStructures or DataFrame."""


import asyncio
import base64
import codecs
import csv as csv_parser
Expand Down Expand Up @@ -147,6 +147,9 @@ async def _parse_flux_response_async(self):
df = self._prepare_data_frame()
if not self._is_profiler_table(metadata.table):
yield df
except (asyncio.exceptions.CancelledError, asyncio.TimeoutError) as ce:
ce.add_note("Stream cancelled during read. Recommended: Check Influxdb client `timeout` setting.")
raise
finally:
self._close()

Expand Down

0 comments on commit 14bc332

Please sign in to comment.