Hola, I have set-up `argowf` and `argoevents` in a...
# ask-metaflow
f
Hola, I have set-up
argowf
and
argoevents
in an
argo
namespace, and I also have
event-bus
, and
event-source
in another namespace called
metaflow
where my workflows/pods run. Everything looks good until here. If I add
@trigger(name="test_trigger_join_artifacts")
to my flows and then create the workflow template the
sensor
and the
sensor-pod
are created. However, when I use
ArgoEvent(name="my_trigger").publish()
the workflow is not triggered . I then tried port-forwarding the
event-source
pod and use `urllib.reques`t to trigger the event/workflow (as in the
ArgoEvents.publish
method) and the workflow is successfully triggered and executed, I have used this:
Copy code
data = {"name": "test_trigger_join_artifacts", 'payload': {'name': 'test_trigger_join_artifacts'}}
requests = urllib.request.Request(
    "<http://localhost:12000/metaflow-event>",
    method="POST",
    headers={"Content-Type": "application/json"},
    data=json.dumps(data).encode("utf-8")
)
urllib.request.urlopen(requests, timeout=10.0)
my
.metaflowconfig
variables look like this:
Copy code
"METAFLOW_KUBERNETES_NAMESPACE": "metaflow",
    "METAFLOW_KUBERNETES_SERVICE_ACCOUNT": "metaflow",
    "METAFLOW_SERVICE_INTERNAL_URL": "<http://metaflow-service:8080>",
    "METAFLOW_SERVICE_URL": "<https://metaflow-service.ai.veo.co>",
    "METAFLOW_SERVICE_HEADERS": "{\"Authorization\": something",
    "METAFLOW_ARGO_EVENTS_EVENT":"metaflow-event",
    "METAFLOW_ARGO_EVENTS_EVENT_BUS":"default",
    "METAFLOW_ARGO_EVENTS_EVENT_SOURCE":"argo-events-webhook",
    "METAFLOW_ARGO_EVENTS_SERVICE_ACCOUNT":"operate-workflow-sa",
    "METAFLOW_ARGO_EVENTS_WEBHOOK_URL": "<http://argo-events-webhook-eventsource-svc.metaflow:12000/metaflow-event>"
I have the feeling that I need to add an ingress to the
event-source
?? I am not sure if I am missing something else? any advice? if the ingress is needed, do you have an example for it?
1