Thomas Wiecki
Jim Crist-Harif
threads_per_worker
from prefect.engine.executors import DaskExecutor exe = DaskExecutor(n_workers=4, threads_per_worker=1)