Hi, when I run the following flow using the local executor all tasks succeed, but when I run it with the dask executor, there are import errors. Is it because the workers don’t have the same environment as the scheduler? How can I fix it?
c
Chris White
04/14/2020, 7:31 PM
Hi @An Hoang - you are correct, your workers need to have all the packages your flow / tasks rely on. To fix it you should run your workers within a python environment matching the one you use to build your flow
j
Jeremiah
04/14/2020, 10:13 PM
@Marvin archive “My flow runs with the local executor but has an import error in Dask”