multimodemodel.DaskWorkflow#

class multimodemodel.DaskWorkflow(domain, solver, client, splitter)[source]#

Workflow distributed on a Dask cluster.

Arguments:#

domain: DomainBase: A domain object that contains the initial state. Using a domain object with initialized history will allow for a warm restart of a model simulation.
solver: SolverBase: The solver defining the problem to solve, the time stepping scheme and the time step.
client: distributed.Client: Client to a Dask cluster.
splitter: SplitVisitorBase: An instance of a subclass of SplitVisitorBase used to split the domain into parts that are distributed across the workers of the client.

__init__(domain, solver, client, splitter)[source]#: Create a client orchestrated workflow.

Methods

`__init__`(domain, solver, client, splitter)	Create a client orchestrated workflow.
`run`(steps[, diag])	Run model forward for a number of steps.
`run_until`(date)	Run until specified date.

Attributes