Skip to main content
Version: v4.25

every

Runs a pipeline periodically at a fixed interval.

every interval:duration { … }

Description​

The every operator repeats running a pipeline indefinitely at a fixed interval. The first run is starts directly when the outer pipeline itself starts.

Every interval, the executor spawns a new pipeline that runs to completion. If the pipeline runs longer than interval, the next run immediately starts.

Examples​

Produce one event per second and enumerate the result​

every 1s {
  from {}
}
enumerate
{"#": 0} // immediately
{"#": 1} // after 1s
{"#": 2} // after 2s
{"#": 3} // after 3s
// … continues like this

Fetch the results from an API every 10 minutes​

every 10min {
  load_http "example.org/api/threats"
  read_json
}
publish "threat-feed"

See Also​

cron