如何在集群模式下为dask设置工作节点上的线程数?

with dask.config.set(pool=ThreadPool(8)):
   bag = db.from_sequence(archives)
   bag.map_partitions(extract_archives).compute()

当我改为使用number_workers时,它仍然是相同的。

with dask.config.set(num_workers=8):
   bag = db.from_sequence(archives)
   bag.map_partitions(extract_archives).compute()

如何设置工作节点中运行的线程数?我在Python3.7中使用Dask。