search

kestra-io / kestra

Infinitely scalable, event-driven, language-agnostic orchestration and scheduling platform to manage millions of workflows declaratively in code.
https://kestra.io
Apache License 2.0
7.64k stars 467 forks source link

Trigger based on Events #1066

Open tchiotludo opened 1 year ago

tchiotludo commented 1 year ago

WIP !

Maybe a flow can emits events: 

  - id: onlyNoInput
    type: io.kestra.core.tasks.events.Emit
    name: 'myEventTable1' 
    args: 
      customData: "{{ outputs.myTask.value }}"

And flow can listen to events: 

triggers:
  - id: listenFlow
    type: io.kestra.core.models.triggers.types.events.Receive
    name: 'myEventTable1'

This will allow more fine grained triggering based on internal processing like tables generated, file created?

anna-geller commented 6 months ago

linking a similar idea https://github.com/kestra-io/kestra-ee/issues/252

anna-geller commented 6 months ago

https://www.notion.so/kestra-io/Custom-Events-and-Webhooks-8a482041fe4a418e83506461fbec2fed?pvs=4