Decorators

class ray

Bases: object

static task(python_callable: Callable[[...], Any] | None = None, multiple_outputs: bool | None = None, config: dict[str, Any] | Callable[[], dict[str, Any]] | None = None, **kwargs: Any) → airflow.decorators.base.TaskDecorator

Decorator to define a task that submits a Ray job.

Parameters:

• python_callable – The callable function to decorate.

• multiple_outputs – If True, will return multiple outputs.

• config – A dictionary of configuration or a callable that returns a dictionary.

• kwargs – Additional keyword arguments.

Returns:

The decorated task.