Stack Overflow
Stack Overflow

Questions tagged [argo-events]

44 questions
6
votes
1 answer

Creating a queue system with Argo Workflows

I am trying to figure out how to set up a work queue with Argo. The Argo Workflows are computationally expensive. We need to plan for many simultaneous requests. The workflow items are added to the work queue via HTTP requests. The flow can be…
Espen Finnesand
  • 475
  • 7
  • 22
5
votes
2 answers

How to parameterize a workflowTempateRef?

I have a WorkflowTemplate "nyc-test-template" which I trigger via Argo Events and PubSub. So, if I publish a message {} into the PubSub topic "argo-events-nyc" the template specified via a workflowTempateRef is started. That does work just fine. Now…
Raffael
  • 19,547
  • 15
  • 82
  • 160
4
votes
1 answer

Argo(events) Trigger an existing ClusterWorkflowTemplate using Sensor

I'm trying to trigger a pre existing ClusterWorkflowTemplate from a post request in argo/ argo-events. I've been following the example here, but i don't want to define the workflow in the sensor- I want to separate this. I can't get the sensor to…
Preston
  • 7,399
  • 8
  • 54
  • 84
2
votes
1 answer

Trigger Argo Workflow with webhook

I have a use case where I want to trigger a argo workflow when github push events occur. So far from what I understand the following would be the steps of my approach, Create Github webhook and then create the following in kubernetes Event…
RandomUser
  • 93
  • 1
  • 8
2
votes
1 answer

Argo Event webhook authentication with Github

I'm trying to integrate the GitHub repo with the Argo Event Source webhook as an example (link). When the configured from the Github event returns an error. 'Invalid Authorization Header'. Code: apiVersion: argoproj.io/v1alpha1 kind:…
Padmasankha
  • 103
  • 1
  • 13
1
vote
1 answer

Argo Kafka Eventsource isn't working with SASL_SSL (SCRAM-SHA-512)

I'm working on Argo Kafka Eventsource and not able to set up SASL_SSL with it. Below is the EventSource manifest apiVersion: argoproj.io/v1alpha1 kind: EventSource metadata: name: kafka namespace: MY_NAMESPACE spec: eventBusName: MY_EVENTBUS …
Aman
  • 193
  • 2
  • 15
1
vote
1 answer

Is there a way to make argo events sensor to run triggers sequentially after completion

Based on my testing, sensor triggers are invoked one by one without waiting for the response. Is there a way to make sensor triggers to wait for one trigger to complete before invoking the next trigger ? Example sensor: apiVersion:…
Sairam Krish
  • 10,158
  • 3
  • 55
  • 67
1
vote
1 answer

How to pass or parse a resource event source body generated from an argo workflow?

I have a resource sensor to trigger a workflow that reports on the original workflow that led to the event - a kind of logger. In the parameters of the sensor, I want to grab the body of the original workflow in order to extract certain values from…
DoctorSoup
  • 141
  • 7
1
vote
0 answers

Argo Events file event source does not detect file

I am building a processing pipeline for genomic data for my master thesis and I am using Argo. Basically, I have a fully functioning processing workflow implemented in Argo Workflows and now I am trying to create an EventSource for detecting when a…
Eros Fabrici
  • 19
  • 3
1
vote
1 answer

Argo Events: Use data filter in sensor to identify modified/added/removed path in mono-repo

I'm using Argo Events and Argo Workflow for my CI/CD chain, which works pretty neat. But I'm having some troubles setting up the data filter for the GitHub webhook payloads of my mono repo. I'm trying to let the sensor only trigger the defined…
nice_pink
  • 435
  • 1
  • 3
  • 16
1
vote
1 answer

Override Argo Workflows generateName from Sensor

I'm looking into customizing workflow names. I see that argo submit --generate-name can override the .metadata.generateName property, but does anyone know if this is possible with a Sensor that triggers a Workflow? I'm using a GitHub event to…
wsams
  • 2,499
  • 7
  • 40
  • 51
1
vote
1 answer

Argo Events: Exposing Webhook Through a K8s Load Balancer on Azure Subnet

I'm trying to route POST requests through a K8s Load Balancer to a Webhook in Argo Events. I can't find any clear documentation on this. I'm able to get the Webhook created and I can successfully communicate with it when I port forward the…
arythmetics
  • 11
  • 2
1
vote
1 answer

Creating a job from a sensor gives “could not find the requested resource” error

I am using argo events/sensors to create a Kubernetes Job , the sensor gets triggered correctly but it is giving me error "the server could not find the requested resource" Here is my sensor.yaml apiVersion: argoproj.io/v1alpha1 kind:…
TruckDriver
  • 1,383
  • 13
  • 28
1
vote
1 answer

Trigger argo workflow template via argo events based on webhook payload data key

im looking for a way to trigger a workflow using webhook json payload key for example if payload is {"action":"copy","id":"someid"} on triggers triggers: template: - "group1" "use this template if action key is 'copy'" - "group2" …
karthik
  • 11
  • 2
0
votes
0 answers

How do I make the git repo and bucket-name a variable so that the values will be dynamic?

I am triggering a sensor from a webhook in argo events I am making a post request which triggers the sensor and the sensor starts up the work flow I want to get the data from body of the post request pass it to git repo apiVersion:…
etranz
  • 891
  • 2
  • 10
  • 29
1
2 3