Argo Events¶

This demonstrates how to use Argo Events to trigger a workflow.

Port¶

Port forward to the argo-events webhook eventsource service:

kubectl -n argo-events port-forward service/webhook-eventsource-svc 12000

In [1]:

from metaflow import namespace
from metaflow.integrations import ArgoEvent

from metaflow import namespace from metaflow.integrations import ArgoEvent

In [2]:

namespace("triggerpipeline-0-vqms")

namespace("triggerpipeline-0-vqms")

Out[2]:

'triggerpipeline-0-vqms'

In [4]:

e = ArgoEvent(
    "ampersand",
    payload={"guid": "1234", "pipeline": "http://app-name?params=true&test=1"},
)

e = ArgoEvent( "ampersand", payload={"guid": "1234", "pipeline": "http://app-name?params=true&test=1"}, )

In [5]:

e.publish()

e.publish()

Argo Event (ampersand) published.

Out[5]:

'e9d3168d-349b-438c-8542-040017e1da72'