1name: process-appel 2 3trigger: 4 kind: event 5 source: tables 6 topic: row.inserted 7 when: "input.data.table == 'appels' and input.data.ids" 8 9steps: 10- id: process-appel 11 kind: function 12 name: process-appel-db-only 13 input: 14 ids: "{{ input.data.ids }}" 15 retry: 16 max: 2 17 backoff_seconds: 60 18