⑥ 複雑なフローを可能にするFlowable Kestra

はじめに

Flowable なタスクはフローを複雑かつ最適にします。これらを使用して、ループや条件などを作成することができます。

より詳細なことは下記を参照してください。

Flowable

下記のサンプルコードはpythonのタスクを並列で実行します。並列処理を行うために Parallel Flowable を使用します。

並列処理の宣言はio.kestra.core.tasks.flows.Parallelで行います。またtasksに並列処理を行う内容を記述します。

id: parallel
namespace: io.kestra.tests

tasks:
  - id: parallel
    type: io.kestra.core.tasks.flows.Parallel
    tasks:
      - id: 1st
        type: io.kestra.core.tasks.debugs.Return
        format: "{{task.id}} > {{taskrun.startDate}}"
      - id: 2nd
        type: io.kestra.core.tasks.debugs.Return
        format: "{{task.id}} > {{taskrun.id}}"
  - id: last
    type: io.kestra.core.tasks.debugs.Return
    format: "{{task.id}} > {{taskrun.startDate}}"

ログとフローを確認するとちゃんと並列に動いていることがわかります。

参考

• Add flowable to your flow