apiVersion: dataflow.argoproj.io/v1alpha1
kind: Pipeline
metadata:
  annotations:
    dataflow.argoproj.io/description: |-
      This example is of the Python 3.9 handler.

      [Learn about handlers](../docs/HANDLERS.md)
    dataflow.argoproj.io/owner: argoproj-labs
  name: 104-python3-9
spec:
  steps:
  - code:
      runtime: python3-9
      source: |
        def handler(msg, context):
            return ("hi! " + msg.decode("UTF-8")).encode("UTF-8")
    name: a
    sinks:
    - kafka:
        topic: middle-topic
    sources:
    - kafka:
        topic: input-topic
  - code:
      runtime: python3-9
      source: |
        def handler(msg, context):
            return ("bye! " + msg.decode("UTF-8")).encode("UTF-8")
    name: b
    sinks:
    - kafka:
        topic: output-topic
    sources:
    - kafka:
        topic: middle-topic