PrefectHQ / prefect-ray

Prefect integrations with Ray
https://prefecthq.github.io/prefect-ray/
Apache License 2.0
63 stars 5 forks source link

use prefect task name as remote function name #103

Closed j-tr closed 10 months ago

j-tr commented 11 months ago

Closes #86

Example

from prefect import flow, task
from prefect_ray import RayTaskRunner
from time import sleep

@task(
    name="Worker Task Name",
)
def worker_function():
    sleep(100)

@flow(task_runner=RayTaskRunner)
def main(
):
    worker_function.submit()

if __name__ == "__main__":
    main()

image

Screenshots

Checklist

azmyrajab commented 11 months ago

this looks good to me - thanks a lot Can we go ahead and merge this?

azmyrajab commented 11 months ago

@PrefectHQ/open-source, sorry to chase, wondering if someone can do a quick review to unblock this? Code looks good and the feature is very nice to have

j-tr commented 10 months ago

@desertaxle it would be great to receive some feedback on this :pray:

desertaxle commented 10 months ago

Tests are failing due to a new version of pytest-asyncio. I'll submit a PR to unblock CI.