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 ae607c5 commit a9ed56eCopy full SHA for a9ed56e
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