daft.context.set_runner_ray#

daft.context.set_runner_ray(address: Optional[str] = None, max_tasks_per_core: Optional[float] = None, max_refs_per_core: Optional[float] = None, batch_dispatch_coeff: Optional[float] = None) → daft.context.DaftContext[source]#

Set the runner for executing Daft dataframes to a Ray cluster

Alternatively, users can set this behavior via environment variables:

  1. DAFT_RUNNER=ray

  2. Optionally, DAFT_RAY_ADDRESS=ray://…

Parameters

address – Address to head node of the Ray cluster. Defaults to None.

Returns

Daft context after setting the Ray runner

Return type

DaftContext