We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3c02af8 commit b96c635Copy full SHA for b96c635
quixstreams/sources/community/influxdb3/influxdb3.py
@@ -74,9 +74,9 @@ class InfluxDB3Source(Source):
74
75
It processes measurements sequentially by gathering/producing a tumbling
76
"time_delta"-sized window of data, starting from 'start_date' and eventually
77
- stopping at 'end_date'.
+ stopping at 'end_date', completing that measurement.
78
79
- Once stopped, it processes the next measurement, until all are complete.
+ It then starts the next measurement, continuing until all are complete.
80
81
If no 'end_date' is provided, it will run indefinitely for a single
82
measurement (which means no other measurements will be processed!).
0 commit comments