如何将本地分布式调度器设置为dask.dataframe的默认调度器？

import dask.dataframe as dd
from dask.distributed import Client, LocalCluster

cluster = LocalCluster()

client = Client(cluster)

dd.config.set(scheduler='distributed')

import dask.dataframe as dd
from dask.distributed import Client, LocalCluster

# 创建本地集群
cluster = LocalCluster()

# 创建Dask客户端并连接到本地集群
client = Client(cluster)

# 设置Dask的默认调度器为本地分布式调度器
dd.config.set(scheduler='distributed')

# 现在可以使用dask.dataframe进行分布式计算
df = dd.read_csv('data.csv')
result = df.groupby('column').sum()

# 打印结果
print(result.compute())