https://prefect.io logo
r

Robin

10/14/2020, 9:55 PM
Hi everybody, we are experimenting with
flow.run_config
instead of
flow.environment
because the DEBUG logging on AWS EKS did not work with
flow.environment
. The good news: DEBUG level logging now works! The bad news: the tasks are not executed parallely, even after setting
flow.executor = DaskExecutor()
Do you know how to enable parallelization?
a

Alexander

10/15/2020, 7:49 PM
I had a similar issue when executor assigned directly to a flow was not respected. Somewhere in their core they use environment executor instead of flow's. Try:
flow.environment = LocalEnvironment(executor=...)