John Lewis
01/13/2023, 7:37 PMDaskTaskRunner
configured to access an existing Dask cluster at <http://my-dask-cluster>
.
@flow(task_runner=DaskTaskRunner(address="http://my-dask-cluster"))
By the way, when I attempted using "http", I got this message:
ValueError: unknown address scheme 'http'
I chose tcp and 8786 based on this line I see in my dask scheduler's log:
distributed.scheduler - INFO - Scheduler at: tcp://10.254.229.85:8786
I exposed the port:
k expose pod mycluster-scheduler --port 8786 --name mycluster
Unfortunately, when I try to run the python script, I see:
OSError: Timed out trying to connect to tcp://hostname:8786 after 30 s
Am I doing something obviously wrong? Any tips for troubleshooting?