apiVersion: dataflow.argoproj.io/v1alpha1
kind: Pipeline
metadata:
  annotations:
    dataflow.argoproj.io/description: This example showcases retry policies.
    dataflow.argoproj.io/owner: argoproj-labs
    dataflow.argoproj.io/test: 'false'
  name: 301-erroring
spec:
  steps:
  - code:
      runtime: python3-9
      source: |
        def handler(msg, context):
            import random
            if random.randint(0, 4) == 1:
                raise Exception("random error")
            return msg
    name: always
    sinks:
    - log: {}
    sources:
    - cron:
        schedule: '*/3 * * * * *'
      retry:
        steps: 99999999
  - code:
      runtime: python3-9
      source: |
        def handler(msg, context):
            import random
            if random.randint(0, 4) == 1:
                raise Exception("random error")
            return msg
    name: never
    sinks:
    - log: {}
    sources:
    - cron:
        schedule: '*/3 * * * * *'
      retry:
        steps: 0