id: filter_active_customers
namespace: company.team

tasks:
  - id: normalize
    type: io.kestra.plugin.core.output.OutputValues
    values:
      records:
        - customer_id: c1
          is_active: true
          total_spent: 120
        - customer_id: c2
          is_active: false
          total_spent: 90

  - id: filter
    type: io.kestra.plugin.transform.Filter
    from: "{{ outputs.normalize.values.records }}"
    where: is_active && total_spent > 100
    onError: SKIP