From f37c3d8474493bf5ea217573ae965e766df5b435 Mon Sep 17 00:00:00 2001 From: Zander <6073079+awmatheson@users.noreply.github.com> Date: Mon, 9 Sep 2024 16:12:37 -0700 Subject: [PATCH] Update docstring --- src/bytewax/influxdb/__init__.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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}"