Hello. Which executor does the local agent uses? I've set LocalDaskExecutor for the flow right before registering (cloud backend), but when a execute via the UI it does not seem to be parallelizing.
w
wiretrack
01/03/2021, 5:56 PM
Had the same problem yesterday, try this:
Copy code
executor = DaskExecutor()
environment = LocalEnvironment(executor)
with Flow('Distributed Flow', environment=environment) as flow: