`pytams.daskutils`

Module Contents

Classes

A Dask wrapper handle cluster and promises.

exception pytams.daskutils.DaskRunnerError[source]

Bases: Exception

Exception class for the Dask runner.

class pytams.daskutils.DaskRunner(parameters: dict)[source]

A Dask wrapper handle cluster and promises.

__enter__()[source]: To enable use of with.

__exit__(*args)[source]: Executed leaving with scope.

make_promise(task, *args)[source]: Return a promise for a task.

execute_promises(list_of_p: list)[source]

Execute a list of promises.

Parameters:: list_of_p – a list of dask promises
Returns:: A list with the return argument of each promised task.