https://prefect.io logo
r

Rob Fowler

02/08/2021, 12:02 PM
seems
Copy code
executor = LocalDaskExecutor(scheduler="processes", num_workers=10)
    for ii in flow.run(executor=executor).result[result].result:
        print(ii)