📦 wrussell1999 / kestra-examples

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28id: 22_advent
namespace: advent

inputs:
  - id: values
    type: JSON
    description: Enter your favorite plugins and tasks
    defaults: |
      [
        {"dbt": ["build", "test", "snapshot"]},
        {"aws": ["s3", "sqs", "sns", "athena"]},
        {"gcp": ["big-query", "gcs", "cloudrun"]}
      ]

tasks:
  - id: parallel
    type: io.kestra.plugin.core.flow.ForEach
    concurrencyLimit: 0
    values: "{{ inputs.values }}"
    tasks:
      - id: set
        type: io.kestra.plugin.redis.string.Set
        url: redis://redis_container:6379/0
        serdeType: STRING
        key: "{{ json(taskrun.value) | keys | first }}"
        value: |
          {{ taskrun.value | jq('.[]') | first }}