Hi we are trying to publish an argo event from inside a pyth Outerbounds #ask-metaflow

Hi, we are trying to publish an argo event from in...

fast-vr-44972

12/07/2023, 4:53 PM

Hi, we are trying to publish an argo event from inside a python script which isn't a flow following the instructions in the doc

Copy code

from metaflow.integrations import ArgoEvent

ArgoEvent(name="data_updated").publish()

It's unable to publish it. We have the correct metaflow and kube config since we can deploy/trigger a flow and can also publish an event from inside the flow. I suppose it's not able to find the necessary env vars. How can we fix it?

✅ 1

limited-tomato-18674

12/07/2023, 4:53 PM

What error are you getting?

fast-vr-44972

12/07/2023, 4:54 PM

Copy code

Unable to publish Argo Event (test_send_extra_var): <urlopen error [Errno -2] Name or service not known>

fast-vr-44972

12/07/2023, 4:55 PM

I also copy pasted the

METAFLOW_ARGO_EVENTS_WEBHOOK_URL

as the

url

argument and it still throws the same error

Copy code

ArgoEvent(name="test_send_extra_var",
        url=<METAFLOW_ARGO_EVENTS_WEBHOOK_URL>).publish(
    payload={'dataset_versions': "1,2", "foo": "not_needed"})

limited-tomato-18674

12/07/2023, 4:55 PM

Are you trying to run this script locally or from inside the cluster?

fast-vr-44972

12/07/2023, 4:56 PM

Locally

limited-tomato-18674

12/07/2023, 4:57 PM

Ah, I see. Is your webhook URL an internal k8s service or is it available over the public internet?

fast-vr-44972

12/07/2023, 4:58 PM

Good question! I suppose it needs to be available over public internet for this to work?

limited-tomato-18674

12/07/2023, 4:58 PM

Yes

fast-vr-44972

12/07/2023, 5:06 PM

Yeah it's a private k8s service.

2 Views

Open in Slack

Previous Next