Buffer

Accumulates events into batches. Flushes when the batch reaches the configured size or the timeout expires.

Configuration

- buffer:
    name: batch
    size: 100
    timeout: "30s"

Field	Type	Default	Description
`name`	string	required	Task name.
`size`	int	required	Number of events per batch.
`timeout`	duration	`30s`	Flush timeout — sends the batch even if not full.
`partition_key`	string		Template for partitioned buffering. Events with the same key are batched together.
`depends_on`	list		Upstream task names.
`retry`	object		Retry configuration.

- buffer:
    name: batch_by_region
    size: 50
    timeout: "10s"
    partition_key: "{{event.data.region}}"

Events are grouped by region. Each partition flushes independently when it reaches 50 events or 10 seconds.