Ray

The Burr Ray integration allows you to run parallel sub-applications on Ray.

class burr.integrations.ray.RayExecutor(shutdown_on_end: bool = False)

Ray parallel executor – implementation of concurrent.futures.Executor. Currently experimental

shutdown(wait=True, **kwargs)

Shuts down the executor by shutting down ray

Parameters:

• wait – Whether to wait – required for hte API but not respected (yet)

• kwargs – Keyword arguments – not used yet

submit(fn, *args, **kwargs)

Submits to ray – creates a python future by calling ray.remote

Parameters:

• fn – Function to submit

• args – Args for the fn

• kwargs – Kwargs for the fn

Returns:

The future for the fn