Hi, im trying to get triggering flows from argo events working but whenever I publish an event I see a webhook pod running and within it's log i see my event, but the flow i created which are supposed to trigger from the event never runs. I have the following setup so far:

"METAFLOW_ARGO_EVENTS_EVENT": "xyzxyz",
    "METAFLOW_ARGO_EVENTS_EVENT_BUS": "default",
    "METAFLOW_ARGO_EVENTS_EVENT_SOURCE": "argo-events-webhook",
    "METAFLOW_ARGO_EVENTS_INTERNAL_WEBHOOK_URL": "webhook-eventsource-test-svc.argo-events.svc.cluster.local",
    "METAFLOW_ARGO_EVENTS_SERVICE_ACCOUNT": "operate-workflow-sa",
    "METAFLOW_ARGO_EVENTS_WEBHOOK_URL": "<https://argo-events.prod>.*******.tech/example"

My flow looks like this:

from metaflow import FlowSpec, step, trigger, pypi
import datetime

@trigger(event='jri-test')
class TestEventFlow(FlowSpec):

    @pypi(python='3.11.3')
    @step
    def start(self):
        print(f"I just got triggered from the jri-test event {datetime.datetime.now()}")
        self.next(self.end)

    @step
    def end(self):
        print("finished...")
        pass

if __name__ == '__main__':
    TestEventFlow()

After deploying the flow with this:

python test-flows/event-triggered-flow.py --environment=conda argo-workflows create

I see a sensor+trigger in the UI, so i guess it works as supposed, however i do think that I have something in my configuration which does not work. argo workflow are under the namespace

argo

and argo-events are under

argo-events

if that has something to do with it. And publish the event using this on my local machine:

python -c "from metaflow.integrations import ArgoEvent; ArgoEvent(name='jri-test').publish();"
# and i also tried this
python -c "from metaflow.integrations import ArgoEvent; ArgoEvent(name='xyzxyz', payload={'name': 'jri-test'}).publish();

I attached screendumps of the webhook pods. And I never see my flow run. I hope someone might be able to help 🙏