John Lewis01/13/2023, 7:37 PM
configured to access an existing Dask cluster at
. @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?