Thomas La Piana
05/05/2020, 11:35 AMflow.run()
locally, it automatically defaults to the local executor instead of using the environment that i set for it, but when i register it and a kube runner picks it up it runs it with the correct environment. does anyone know why?Zachary Hughes
05/05/2020, 1:12 PMflow.run()
directly, your flow is run without an environment, meaning it defaults to the LocalExecutor
.
To work around that, you should be able to provide an executor to run
, eg flow.run(executor=YourDesiredExecutor)
.
I think there's some room for us to clarify environments and executors, so thanks for putting that on our radar!Thomas La Piana
05/06/2020, 6:22 AM