{"id":23756,"library":"flytekitplugins-ray","title":"Flytekit Ray Plugin","description":"This package provides Ray integration for Flyte workflows, enabling distributed execution on Ray clusters. Current version: 1.16.19. Released approximately monthly alongside flytekit core.","status":"active","version":"1.16.19","language":"python","source_language":"en","source_url":"https://github.com/flyteorg/flytekit/tree/master/plugins/flytekitplugins-ray","tags":["flyte","ray","distributed-computing","workflow"],"install":[{"cmd":"pip install flytekitplugins-ray","lang":"bash","label":"Standard install"}],"dependencies":[{"reason":"Core dependency; must be installed with compatible version.","package":"flytekit","optional":false},{"reason":"Ray runtime; version >=2.0 required.","package":"ray","optional":false}],"imports":[{"wrong":"from flytekitplugins.ray import Ray","symbol":"Ray","correct":"from flytekitplugins.ray import Ray"}],"quickstart":{"code":"from flytekit import task, workflow\nfrom flytekitplugins.ray import Ray, RayJobConfig\n\n@task(task_config=Ray(job_config=RayJobConfig(worker_groups=[...])))\ndef my_ray_task() -> str:\n    import ray\n    ray.init()\n    return \"Ray task completed\"\n\n@workflow\ndef wf() -> str:\n    return my_ray_task()\n\nif __name__ == \"__main__\":\n    print(wf())","lang":"python","description":"Basic Flyte task configured to run on Ray."},"warnings":[{"fix":"Replace 'from flytekitplugins.ray import RayExecutor' with 'from flytekitplugins.ray import Ray' and adjust usage.","message":"In flytekit >=1.12, the Ray plugin API changed: use 'Ray' task_config instead of the old 'RayExecutor'.","severity":"breaking","affected_versions":">=1.12.0"},{"fix":"Do not call ray.init() if you are using RayJobConfig; Flyte handles cluster startup automatically.","message":"Ray initialization inside the task may conflict with the Flyte-managed Ray cluster. Avoid calling ray.init() in tasks that use RayJobConfig.","severity":"gotcha","affected_versions":"all"},{"fix":"Use 'worker_group_spec' instead of 'worker_groups' when available, or check for deprecation warnings.","message":"The 'RayJobConfig' worker_groups parameter is being replaced by 'worker_group_spec' in future versions.","severity":"deprecated","affected_versions":">=1.16.0"}],"env_vars":null,"search_vec":"'1.16.19':20 'alongsid':24 'approxim':22 'cluster':17 'comput':31 'core':26 'current':18 'distribut':13,30 'distributed-comput':29 'enabl':12 'execut':14 'flyte':10,27 'flytekit':1,25 'integr':8 'month':23 'packag':5 'plugin':3 'provid':6 'ray':2,7,16,28 'releas':21 'version':19 'workflow':11,32","created_at":"2026-05-01T08:09:27.229428+00:00","updated_at":"2026-05-01T08:09:27.229428+00:00","problems":{"verify_error":"╭───────────────────── Traceback (most recent call last) ──────────────────────╮\n│ in <module>:1                                                                │\n╰──────────────────────────────────────────────────────────────────────────────╯\nImportError: cannot import name 'Ray' from 'flytekitplugi"},"ecosystem":"pypi","meta_description":null,"install_score":null,"quickstart_score":null,"quickstart_tag":null,"pypi_latest":"1.16.23","cli_name":"","cli_version":null,"type":"library","homepage":null,"github":null,"docs":null,"changelog":null,"pypi":"https://pypi.org/project/flytekitplugins-ray/","npm":null,"openapi_spec":null,"status_page":null,"smithery":null,"categories":["workflow","ai-ml","aws"],"base_url":null,"auth_type":null,"provenance":{"verified_status":"import_fail","verified_at":"2026-07-03","last_verified":"2026-07-03","next_check":"2026-07-10","install_tag":null}}