Skip to content

Commit

Permalink
chore: add kafka-ttl sensor example (#2718)
Browse files Browse the repository at this point in the history
Signed-off-by: liang <xuliang1@uw.edu>
  • Loading branch information
xuliang2019 committed Jul 19, 2023
1 parent 5b0e16c commit f47a681
Showing 1 changed file with 47 additions and 0 deletions.
47 changes: 47 additions & 0 deletions examples/sensors/kafka-ttl.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,47 @@
apiVersion: argoproj.io/v1alpha1
kind: Sensor
metadata:
name: kafka
spec:
template:
serviceAccountName: operate-workflow-sa
dependencies:
- name: test-dep
eventSourceName: kafka
eventName: example
triggers:
- template:
name: kafka-workflow-trigger
k8s:
operation: create
source:
resource:
apiVersion: argoproj.io/v1alpha1
kind: Workflow
metadata:
generateName: kafka-workflow-with-ttl-
spec:
ttlStrategy:
secondsAfterCompletion: 10 # Time to live after workflow is completed, replaces ttlSecondsAfterFinished
secondsAfterSuccess: 5 # Time to live after workflow is successful
secondsAfterFailure: 5 # Time to live after workflow fails
entrypoint: whalesay
arguments:
parameters:
- name: message
# this is the value that should be overridden
value: hello world
templates:
- name: whalesay
inputs:
parameters:
- name: message
container:
image: docker/whalesay:latest
command: [cowsay]
args: ["{{inputs.parameters.message}}"]
parameters:
- src:
dependencyName: test-dep
dataKey: body
dest: spec.arguments.parameters.0.value

0 comments on commit f47a681

Please sign in to comment.