Nuno Silva
08/19/2020, 2:54 PMflow.run(...)
but when I flow.register(...
) and then run it from the UI, I get errors in the dask workers in k8s saying that cannot connect to localhost:4200
. which makes sense since that localhost:4200 has to be replaced by the IP where the prefect server is running. how to do that? (https://github.com/PrefectHQ/prefect/issues/3185)josh
08/19/2020, 2:55 PM--api
flagNuno Silva
08/19/2020, 3:00 PMprefect agent start --api <server_ip>
?josh
08/19/2020, 3:01 PMprefect agent start
or prefect agent install
you can say --api <server_ip>
Nuno Silva
08/19/2020, 3:10 PMjosh
08/19/2020, 3:11 PM--show-flow-logs
flag to see what the logs from the process are showing?Nuno Silva
08/19/2020, 3:13 PMjosh
08/19/2020, 3:15 PM/graphql
to the --api
endpoint you are passing in? It looks like it’s attempting to talk to /graphql/graphql
(the client automatically adds it)Nuno Silva
08/19/2020, 3:17 PM--api= server_ip
or 2) --api= server_ip:4200
?josh
08/19/2020, 3:17 PM4200
portNuno Silva
08/19/2020, 3:18 PMjosh
08/19/2020, 3:19 PMLocalEnvironment
and see what happensNuno Silva
08/19/2020, 3:21 PMflow.run
it worksjosh
08/19/2020, 3:24 PMflow.run
doesn’t make any calls to the server so I would expect that to succeed. Could you try the reregister w/o the executor?Nuno Silva
08/19/2020, 3:25 PM--api
josh
08/19/2020, 3:31 PMfrom prefect import Client
# add the /graphql this time
c = Client(api_server=<endpoint>/graphql)
c.graphql("{hello}")
and see if it raises an errorNuno Silva
08/19/2020, 3:34 PMjosh
08/19/2020, 3:34 PMNuno Silva
08/19/2020, 3:38 PMprefect start server
and then prefect start agent
. the dask cluster (executor) is a dask-kubernetes cluster that I deployed myself in azure akslocalenvironment
without an executor, having the prefect server and agent inside the same machine works fine, the agent finds the flows and runs themjosh
08/19/2020, 3:39 PM--api
or no?Nuno Silva
08/19/2020, 3:40 PMc = Client(api_server=<endpoint>/graphql)
works from my local machine. when I run that from a python terminal in the VM it doesn't workjosh
08/19/2020, 3:43 PM--api
flag and then it will be propagated down to the workers
• Keep your agent on that instance without setting --api
and instead on your dask cluster somehow set the env var PREFECT___CLOUD___API=<endpoint>
Nuno Silva
08/19/2020, 3:43 PMjosh
08/19/2020, 3:44 PMNuno Silva
08/19/2020, 3:47 PMjosh
08/19/2020, 3:47 PMNuno Silva
08/19/2020, 3:48 PMprefect agent start --api server_ip:4200
it fails immediately with requests.exceptions.ConnectionError: HTTPConnectionPool(host='localhost', port=4200)
josh
08/19/2020, 3:52 PMNuno Silva
08/19/2020, 3:53 PM--api
flag it only fails when the flow is scheduled, since only then it tries to use itjosh
08/19/2020, 3:53 PMexport
PREFECT___CLOUD___API=<endpoint>
in the same process on your VM before you start the agent and see if it resolves anythingNuno Silva
08/19/2020, 4:03 PMjosh
08/19/2020, 4:06 PMNuno Silva
08/19/2020, 4:12 PMjosh
08/19/2020, 4:14 PMNuno Silva
08/19/2020, 4:28 PMAttributeError: 'NoneType' object has no attribute 'rstrip'
in python3.8/site-packages/azure/storage/blob/_shared/base_client.py", line 349, in parse_connection_str
PREFECT___CLOUD___API
in dask workers in kubernetes doesn't workjosh
08/19/2020, 4:30 PM"azure-storage-blob >= 12.1.0, < 13.0"
, I don’t know too much about this storage integration so if there are some updates it needs due to azure API changes we welcome the contribution hahaNuno Silva
08/19/2020, 4:32 PMDave
10/30/2020, 3:17 PMAttributeError: 'NoneType' object has no attribute 'rstrip'