Registry / workflow / flytekitplugins-ray

flytekitplugins-ray

library1.16.23pypypiunverified

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.

workflow ai-ml aws

pip install flytekitplugins-ray

package ↗

INSTALL

IMPORT

SIG · FLYTEKITPLUGINS-RA

flytekitplugins-ray

workflowpythonv1.16.23

Install

28.3s avg

Import

—

Disk

410MB

Pass rate

4/ 10

Env Coverage4 / 10

glibc

3.9–3.13

musl

3.9–3.13

Install & Compatibility

Where this runs

tested against v1.16.23 · pip install

no network on importno background threads

Install × environment matrix

Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux

musl

glibc

py 3.10

✕ build_error

✓ 29.8s

py 3.11

✕ build_error

✓ 28.2s

py 3.12

✕ build_error

✓ 23.1s

py 3.13

✕ build_error

py 3.9

✕ build_error

✓ 32.3s

410MB installed

● package 410MB

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

Ray

✓ from flytekitplugins.ray import Ray

✗ from flytekitplugins.ray import Ray

Basic Flyte task configured to run on Ray.

from flytekit import task, workflow from flytekitplugins.ray import Ray, RayJobConfig @task(task_config=Ray(job_config=RayJobConfig(worker_groups=[...]))) def my_ray_task() -> str: import ray ray.init() return "Ray task completed" @workflow def wf() -> str: return my_ray_task() if __name__ == "__main__": print(wf())

Debug

Known issues

breakingIn flytekit >=1.12, the Ray plugin API changed: use 'Ray' task_config instead of the old 'RayExecutor'.

fix

Replace 'from flytekitplugins.ray import RayExecutor' with 'from flytekitplugins.ray import Ray' and adjust usage.

affects: >=1.12.0

gotchaRay initialization inside the task may conflict with the Flyte-managed Ray cluster. Avoid calling ray.init() in tasks that use RayJobConfig.

fix

Do not call ray.init() if you are using RayJobConfig; Flyte handles cluster startup automatically.

affects: all

deprecatedThe 'RayJobConfig' worker_groups parameter is being replaced by 'worker_group_spec' in future versions.

fix

Use 'worker_group_spec' instead of 'worker_groups' when available, or check for deprecation warnings.

affects: >=1.16.0

Upgrade

Version history

1.16.23latest on PyPI · released Jun 2, 2026

Audit

Dependencies

flytekitrequiredCore dependency; must be installed with compatible version.

rayrequiredRay runtime; version >=2.0 required.

Agent activity

21 hits · last 30 days

node

OpenAI (training)

Resources

packagehttps://pypi.org/project/flytekitplugins-ray/ ↗