seems ``` executor = LocalDaskExecutor(scheduler="processes", num_workers=10) for ii in flow....

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)

Open in Slack

Previous Next

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.