Cab Maddux
02/14/2020, 1:42 PMjosh
02/14/2020, 2:15 PMBraun Reyes
02/14/2020, 3:22 PMif __name__ == '__main__':
from prefect.engine.executors import DaskExecutor
flow.schedule = None
executor = DaskExecutor(n_workers=1, threads_per_worker=3)
flow.run(executor=executor)
Cab Maddux
02/14/2020, 3:57 PMBraun Reyes
02/14/2020, 3:58 PMCab Maddux
02/14/2020, 4:00 PM