diff --git a/src/bytewax/influxdb/__init__.py b/src/bytewax/influxdb/__init__.py index 83f3ac7..14fb959 100644 --- a/src/bytewax/influxdb/__init__.py +++ b/src/bytewax/influxdb/__init__.py @@ -49,7 +49,7 @@ def next_batch(self) -> List[RecordBatch]: Returns: List[RecordBatch]: A list of data points retrieved from InfluxDB returned - as Record Batches. + as Arrow Record Batches. That can convert into dataframes or similar. """ current_time = datetime.now(timezone.utc) query = f"""SELECT * from "{self.measurement}"