Miguel
03/23/2021, 5:25 PM[2021-03-23 17:16:53+0000] ERROR - prefect.my-flow | Unexpected error occured in FlowRunner: ModuleNotFoundError("No module named 'prefect'")
This is what I'm doing:
executor = DaskExecutor("my-dask-cluster-ip")
flow.run(executor=executor)
If I use other executors (LocalExecutor or LocalDaskExecutor) it runs fine.
Any idea on what I can do to address this issue?Mariia Kerimova
03/23/2021, 5:29 PMflow.register(project_name="<name_of_project">)
?Miguel
03/23/2021, 5:43 PMMariia Kerimova
03/23/2021, 6:34 PMMiguel
03/23/2021, 7:13 PMimport prefect
from prefect.executors import DaskExecutor
@prefect.task
def my_task():
return 1
with prefect.Flow("my-flow") as flow:
my_task()
executor = DaskExecutor("external-ip:8786")
flow.run(executor=executor)
Mariia Kerimova
03/23/2021, 10:11 PM