tooptoop4

currenttimestamp format?

3

my sensor is complaining about dataTemplate format ``` parameters: - src: dependencyName: test-dep dataKey: body dest: spec.arguments.parameters.0.value - src: dependencyName: test-dep dataTemplate: "{{ now | unixEpoch }}-" dest: metadata.generateName operation:...

event batching

2

instead of triggering 1 workflow/pod per event want to trigger 1 workflow/pod per 10 events. ie send 10 different sqs messages together

Make EventBus AckWait configurable

1

In debugging https://github.com/argoproj/argo-events/issues/1547 ("stan: publish ack timeout") i came across https://github.com/nats-io/nats-streaming-server/issues/958#issuecomment-546408655, one of the suggestions is "the server was not able to respond within the publisher's ack wait" Below shows...

DB event source

3

**Is your feature request related to a problem? Please describe.** Currently, argo-events only supports data-driven event pipelines for S3 like stores. This is a proposal to build a gateway to...

https://github.com/argoproj/argo-events/blob/master/examples/event-sources/aws-sqs.yaml#L26 accepts a literal queue name, would be great if it could instead resolve the queue name from output of a bash command ie `dig someendpoint`

is there any recommended livenessProbe for eventSource and sensor?

# Summary allow configuring event sources/sensors with a time range that they cannot process events in # Use Cases My target DB that my workflows write data to has a...

Allow option to not delete SQS message

5

https://github.com/argoproj/argo-events/blob/b4c3b5ce8c00c0541f831ff2c5e5492f0ef71fdf/eventsources/sources/awssqs/start.go#L114 is deleting the message read from SQS. This is problematic if my workflow fails to act on the message. I would like an option where the event source does...

Kafka source - make partition optional

2

https://github.com/argoproj/argo-events/blob/master/api/event-source.md#kafkaeventsource shows partition as mandatory, it should be optional

dataKey missing from argo_archived_workflows persistence table

1

I created kind: Sensor and last part of yaml has this: ``` parameters: - src: dependencyName: test-dep dataKey: body dest: spec.arguments.parameters.0.value ``` but these values like dataKey don't show up...