Client

Dask client for the computation.

from dask.distributed import Client
 
client = Client(cluster)
 
# Or
 
scheduler_ip = "tcp://IP"
client = Client(scheduler_ip)