Sen
03/03/2022, 10:28 AMAnna Geller
03/03/2022, 11:06 AMSen
03/03/2022, 11:08 AMAnna Geller
03/03/2022, 11:12 AMSen
03/03/2022, 11:14 AMFailed to load and execute Flow's environment: ModuleNotFoundError("No module named '/app/workflow/flow'")
Anna Geller
03/03/2022, 11:29 AMSen
03/03/2022, 11:30 AMFailed to load and execute Flow's environment: ModuleNotFoundError("No module named '/app/workflow/flow'")
This is my flow:
import prefect
from prefect import Flow, task
from prefect.run_configs import DockerRun
from prefect.storage import Local
from components.componentA import ComponentA
from components.componentB import ComponentB
@task
def test_task():
logger = prefect.context.get("logger")
x = ComponentA(2)
y = ComponentB(2)
x = x.n + y.n
<http://logger.info|logger.info>(f"Test {x}!") # Should return 4
return
with Flow("docker_example",
storage=Local(path="/app/workflow/flow.py", stored_as_script=True, add_default_labels=False),
run_config=DockerRun(image="test:latest")) as flow:
test_task()
flow.register("SampleFlows", labels=["TestFlow"])
Anna Geller
03/03/2022, 11:32 AMSen
03/03/2022, 11:38 AMENV PYTHONPATH="$PYTHONPATH:/app"
Anna Geller
03/03/2022, 12:30 PM