Christian Vogel
07/07/2022, 10:59 AM(begin_task_run pid=141324) ImportError: cannot import name 'SubprocessFlowRunner' from partially initialized module 'prefect.flow_runners' (most likely due to a circular import) (/home/christian/Documents/ray_and_prefect/env/lib/python3.9/site-packages/prefect/flow_runners/__init__.py)
I am using the following dependencies: prefect==2.0b7 prefect-ray==0.1.0 ray==1.13.0
Apparently I am doing something wrong with my dependencies or when I am importing them. Do you have any idea?from prefect import task, flow
from prefect_ray import RayTaskRunner
from prefect.deployments import DeploymentSpec
@task
def say_hello(name):
print(f"hello {name}")
@flow(name="temp-flow-example", task_runner=RayTaskRunner(address="auto"))
def greetings():
say_hello("Ford")
DeploymentSpec(
name="temp-flow-example",
flow=greetings
)
from prefect.flow_runners import SubprocessFlowRunner
which them leads to some import issues because of the already imported:
from prefect_ray import RayTaskRunner
Is that possible?Anna Geller
07/07/2022, 11:57 AMflow_runner=SubprocessFlowRunner(condaenv="yourcondavenv"),
Failed to read dashboard log: [Errno 2] No such file or directory: '/tmp/ray/session_2022-07-07_14-08-35_008202_6668/logs/dashboard.log'
Christian Vogel
07/07/2022, 12:24 PMAnna Geller
07/07/2022, 12:25 PMMarvin
07/07/2022, 12:26 PMChristian Vogel
07/07/2022, 12:48 PM