Rob Fowler
executor = LocalDaskExecutor(scheduler="processes", num_workers=10) for ii in flow.run(executor=executor).result[result].result: print(ii)