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?

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

@Marvin archive “My flow runs with the local executor but has an import error in Dask”