https://prefect.io logo
t

Thomas Wiecki

04/28/2020, 3:29 PM
is there a work-around?
j

Jim Crist-Harif

04/28/2020, 4:12 PM
I recommend using the distributed scheduler. If you can't use threads with your tasks, you could specify that each worker gets only one thread with
threads_per_worker
.
Copy code
from prefect.engine.executors import DaskExecutor
exe = DaskExecutor(n_workers=4, threads_per_worker=1)