Piotr Bródka
11/08/2022, 11:17 AMOscar Björhn
11/08/2022, 11:21 AMRyan Peden
11/08/2022, 2:30 PMaddress
parameter when creating the task runner, like so:
from prefect import flow
from prefect_ray.task_runners import RayTaskRunner
@flow(task_runner=RayTaskRunner(address="ray://<your-ray-cluster-ip>:8786"))
def my_flow():
...