tasks.lastSuccess() function

Flux 0.84.0+

The tasks.lastSuccess() function returns the time of last successful run of the InfluxDB task or the value of the orTime parameter if the task has never successfully run.

import "influxdata/influxdb/tasks"

tasks.lastSuccess(orTime: 2020-01-01T00:00:00Z)



The default time value returned if the task has never successfully run.


Query data since the last successful task run
import "influxdata/influxdb/tasks"

options task = {
  name: "Example task",
  every: 30m

from(bucket: "example-bucket")
  |> range(start: tasks.lastSuccess(orTime: -task.every))
  // ...

Upgrade to InfluxDB Cloud or InfluxDB 2.0!

InfluxDB Cloud and InfluxDB OSS 2.0 ready for production.