Skip to content

Retry Workflow

This examples uses a RetryStrategy at the Workflow level, rather than the template level.

The Workflow is functionally equivalent to the Retry Container To Completion example, but as the RetryStrategy is on the Workflow itself, it will apply by default to all templates in the Workflow.

 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
from hera.workflows import (
    Container,
    RetryStrategy,
    Workflow,
    models as m,
)

with Workflow(
    generate_name="retry-workflow-",
    entrypoint="retry-backoff",
    retry_strategy=RetryStrategy(
        limit="10",
        backoff=m.Backoff(
            duration="1",
            factor="2",
            max_duration="1m",
        ),
    ),
) as w:
    retry_backoff = Container(
        name="retry-backoff",
        image="python:alpine3.6",
        command=["python", "-c"],
        args=["import random; import sys; exit_code = random.choice(range(0, 5)); sys.exit(exit_code)"],
    )

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
apiVersion: argoproj.io/v1alpha1
kind: Workflow
metadata:
  generateName: retry-workflow-
spec:
  entrypoint: retry-backoff
  templates:
  - name: retry-backoff
    container:
      image: python:alpine3.6
      args:
      - import random; import sys; exit_code = random.choice(range(0, 5)); sys.exit(exit_code)
      command:
      - python
      - -c
  retryStrategy:
    limit: '10'
    backoff:
      duration: '1'
      factor: '2'
      maxDuration: 1m

Comments