Skip to content

K8S Wait Wf

Note

This example is a replication of an Argo Workflow example in Hera. The upstream example can be found here.

 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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
from hera.workflows import Resource, Step, Steps, Workflow
from hera.workflows.models import Arguments, Inputs, Outputs, Parameter, ValueFrom

with Workflow(
    api_version="argoproj.io/v1alpha1",
    kind="Workflow",
    generate_name="k8s-wait-wf-",
    entrypoint="k8s-wait-wf",
) as w:
    with Steps(
        name="k8s-wait-wf",
    ) as invocator:
        Step(
            name="create-wf",
            template="create-wf",
        )
        Step(
            arguments=Arguments(
                parameters=[
                    Parameter(
                        name="wf-name",
                        value="{{steps.create-wf.outputs.parameters.wf-name}}",
                    )
                ],
            ),
            name="wait-wf",
            template="wait-wf",
        )
    Resource(
        name="create-wf",
        outputs=Outputs(
            parameters=[
                Parameter(
                    name="wf-name",
                    value_from=ValueFrom(
                        json_path="{.metadata.name}",
                    ),
                )
            ],
        ),
        action="create",
        manifest='apiVersion: argoproj.io/v1alpha1\nkind: Workflow\nmetadata:\n  generateName: sleep-\nspec:\n  entrypoint: sleep\n  templates:\n  - name: sleep\n    container:\n      image: alpine:latest\n      command: [sleep, "20"]\n',
    )
    Resource(
        inputs=Inputs(
            parameters=[
                Parameter(
                    name="wf-name",
                )
            ],
        ),
        name="wait-wf",
        action="get",
        failure_condition="status.phase in (Failed, Error)",
        manifest="apiVersion: argoproj.io/v1alpha1\nkind: Workflow\nmetadata:\n  name: {{inputs.parameters.wf-name}}\n",
        success_condition="status.phase == Succeeded",
    )

 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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
apiVersion: argoproj.io/v1alpha1
kind: Workflow
metadata:
  generateName: k8s-wait-wf-
spec:
  entrypoint: k8s-wait-wf
  templates:
  - name: k8s-wait-wf
    steps:
    - - name: create-wf
        template: create-wf
    - - name: wait-wf
        template: wait-wf
        arguments:
          parameters:
          - name: wf-name
            value: '{{steps.create-wf.outputs.parameters.wf-name}}'
  - name: create-wf
    outputs:
      parameters:
      - name: wf-name
        valueFrom:
          jsonPath: '{.metadata.name}'
    resource:
      action: create
      manifest: |
        apiVersion: argoproj.io/v1alpha1
        kind: Workflow
        metadata:
          generateName: sleep-
        spec:
          entrypoint: sleep
          templates:
          - name: sleep
            container:
              image: alpine:latest
              command: [sleep, "20"]
  - name: wait-wf
    inputs:
      parameters:
      - name: wf-name
    resource:
      action: get
      failureCondition: status.phase in (Failed, Error)
      manifest: |
        apiVersion: argoproj.io/v1alpha1
        kind: Workflow
        metadata:
          name: {{inputs.parameters.wf-name}}
      successCondition: status.phase == Succeeded

Comments