Trigger a flow after some delay

[tchiotludo]

on Flow, a nice feature will be allow to trigger the flow after xx minutes / seconds / hour.
When the flow is trigger, instead of sending directly to the Queue, just keep it on a Kafka State store and use punctuate to send it later

[sahmed007]

Hi, I'm interested in this project and would like to work on this. Can you please provide some guidance on where to start with this task?

[tchiotludo]

Just need to think a little more.
My last thought was to use the Pause task and add a delay parameter that will let the flow in PAUSE state, wait the delay, and continue after.
For the User design, it will be cool, the flow will be clearly show as pause on the UI.

For the technical point, do you have background on Java & Kafka Streams ?

[tchiotludo]

I've try a first look and first implementation, not so easy than I think and need to well know the application architecture in order to work on it
Will keep you informed

[tchiotludo]

@sahmed007: it's available on latest dev image
Here is an example :

id: pause-delay
namespace: io.kestra.tests

tasks:
  - id: pause
    type: io.kestra.core.tasks.flows.Pause
    delay: PT5S
    tasks:
      - id: ko
        type: io.kestra.core.tasks.scripts.Bash
        commands:
          - echo "trigger 5 seconds pause"

  - id: last
    type: io.kestra.core.tasks.debugs.Return
    format: "{{task.id}} > {{taskrun.startDate}}"

2022-04-11T11-53-39D0-12.mp4