Generate

Produces events on a schedule. Source task — typically first in a flow.

Configuration

- generate:
    name: ticker
    interval: "5s"

Field	Type	Default	Description
`name`	string	required	Task name.
`payload`	object		Structured data to include in each event.
`interval`	duration		Interval schedule (e.g., `5s`, `1m`). Mutually exclusive with `cron`.
`cron`	string		Cron expression. Mutually exclusive with `interval`.
`timezone`	string	`UTC`	Timezone for cron evaluation.
`count`	int		Max events to generate. Runs indefinitely if omitted.
`allow_rerun`	bool	false	Reset the counter on restart.
`ack_timeout`	duration	wait indefinitely	Max time to wait for flow completion before the next scheduled run. Generated events that fail or time out skip the cache update so the next run retries from the same timestamp.
`depends_on`	list		Upstream task names.
`retry`	object		Retry configuration.

Format: JSON. Includes user-defined payload fields (if configured) plus system info.

Field	Type	Description
`system_info.last_run_time`	int	Unix timestamp (seconds) of the current run.
`system_info.next_run_time`	int / null	Unix timestamp (seconds) of the next scheduled run.

Interval with payload:

- generate:
    name: heartbeat
    interval: "1m"
    payload:
      type: heartbeat
      source: flowgen

Cron schedule:

- generate:
    name: daily_trigger
    cron: "0 2 * * *"
    timezone: "America/New_York"

Run once:

- generate:
    name: init
    interval: "1s"
    count: 1