Dask Executor

class orion.executor.dask_backend.Dask(n_workers=- 1, client=None, **config)

Attributes

in_worker

Methods

submit(function, *args, **kwargs)	Submit work to the executor for asynchronous execution
wait(futures)	Wait for all futures to complete execution.

submit(function, *args, **kwargs)

Submit work to the executor for asynchronous execution

Parameters

function: a callable object

A function to be executed by the executor. The function must be serializable.

*args, **kwargs:

Arguments for the function. The arguments must be serializable.

wait(futures)

Wait for all futures to complete execution.

Parameters

futures: `concurrent.futures.Futures` or equivalent interface

The objects returned by submit() of the executor.