As per the ticket above, we've created a new webhook-based argo EventSource, which along with a new Sensor will publish events to the NATS EventBus. The current Run Completion Event Sensor (which is per-Provider) now sends the event via HTTP through the webhook.
Closes https://github.com/sky-uk/kfp-operator/issues/356.
As per the ticket above, we've created a new webhook-based argo EventSource, which along with a new Sensor will publish events to the NATS EventBus. The current Run Completion Event Sensor (which is per-Provider) now sends the event via HTTP through the webhook.
Tested in Vertex AI and Kubeflow Pipelines.
Architecture after this change: