Skip to content

Workflow Template Dag

Note

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

from hera.workflows import DAG, Task, Workflow
from hera.workflows.models import TemplateRef

with Workflow(
    generate_name="workflow-template-dag-diamond-",
    entrypoint="diamond",
) as w:
    whalesay_template_ref = TemplateRef(name="workflow-template-whalesay-template", template="whalesay-template")
    inner_template_ref = TemplateRef(name="workflow-template-inner-dag", template="inner-diamond")
    with DAG(name="diamond"):
        A = Task(name="A", template_ref=whalesay_template_ref, arguments={"message": "A"})
        B = Task(name="B", template_ref=whalesay_template_ref, arguments={"message": "B"})
        C = Task(name="C", template_ref=inner_template_ref)
        D = Task(name="D", template_ref=whalesay_template_ref, arguments={"message": "D"})

        A >> [B, C] >> D
apiVersion: argoproj.io/v1alpha1
kind: Workflow
metadata:
  generateName: workflow-template-dag-diamond-
spec:
  entrypoint: diamond
  templates:
  - dag:
      tasks:
      - arguments:
          parameters:
          - name: message
            value: A
        name: A
        templateRef:
          name: workflow-template-whalesay-template
          template: whalesay-template
      - arguments:
          parameters:
          - name: message
            value: B
        depends: A
        name: B
        templateRef:
          name: workflow-template-whalesay-template
          template: whalesay-template
      - depends: A
        name: C
        templateRef:
          name: workflow-template-inner-dag
          template: inner-diamond
      - arguments:
          parameters:
          - name: message
            value: D
        depends: B && C
        name: D
        templateRef:
          name: workflow-template-whalesay-template
          template: whalesay-template
    name: diamond

Comments