BaseDaskBackend¶

class openff.evaluator.backends.dask.BaseDaskBackend(number_of_workers=1, resources_per_worker=<openff.evaluator.backends.backends.ComputeResources object>)[source]¶

A base dask backend class, which implements functionality which is common to all other dask based backends.

__init__(number_of_workers=1, resources_per_worker=<openff.evaluator.backends.backends.ComputeResources object>)[source]¶: Constructs a new BaseDaskBackend object.

Methods

`__init__`([number_of_workers, …])	Constructs a new BaseDaskBackend object.
`start`()	Start the calculation backend.
`stop`()	Stop the calculation backend.
`submit_task`(function, args, *kwargs)	Submit a task to the compute resources managed by this backend.

Attributes

started

Returns whether this backend has been started yet.

start()[source]¶: Start the calculation backend.

stop()[source]¶: Stop the calculation backend.

property started¶

Returns whether this backend has been started yet.

Type: bool

abstract submit_task(function, *args, **kwargs)¶

Submit a task to the compute resources managed by this backend.

Parameters: function (function) – The function to run.
Returns: Returns a future object which will eventually point to the results of the submitted task.
Return type: Future