8.2.12.1. Solution

class Solution(dsp=None, inputs=None, outputs=None, wildcard=False, cutoff=None, inputs_dist=None, no_call=False, rm_unused_nds=False, wait_in=None, no_domain=False, _empty=False, index=(-1, ), full_name=())

Solution class for dispatch result.

Methods

__init__	Initialize self.
clear
copy
fromkeys	Create a new ordered dictionary with keys from iterable and values set to value.
get	Return the value for key if key is in the dictionary, else default.
get_node	Returns a sub node of a dispatcher.
get_sub_dsp_from_workflow	Returns the sub-dispatcher induced by the workflow from sources.
items
keys
move_to_end	Move an existing element to the end (or beginning if last is false).
plot	Plots the Dispatcher with a graph in the DOT language with Graphviz.
pop	value.
popitem	Remove and return a (key, value) pair from the dictionary.
result	Set all asynchronous results.
search_node_description
setdefault	Insert key with a value of default if key is not in the dictionary.
update	If E is present and has a .keys() method, then does: for k in E: D[k] = E[k] If E is present and lacks a .keys() method, then does: for k, v in E: D[k] = v In either case, this is followed by: for k in F: D[k] = F[k]
values
web	Creates a dispatcher Flask app.

__init__(dsp=None, inputs=None, outputs=None, wildcard=False, cutoff=None, inputs_dist=None, no_call=False, rm_unused_nds=False, wait_in=None, no_domain=False, _empty=False, index=(-1, ), full_name=())

Initialize self. See help(type(self)) for accurate signature.

Attributes

pipe	Returns the full pipe of a dispatch run.

result(timeout=None)

Set all asynchronous results.

Parameters:timeout (float) – The number of seconds to wait for the result if the futures aren’t done. If None, then there is no limit on the wait time. Returns:Update Solution. Return type:Solution

get_sub_dsp_from_workflow(sources, reverse=False, add_missing=False, check_inputs=True)

Returns the sub-dispatcher induced by the workflow from sources.

The induced sub-dispatcher of the dsp contains the reachable nodes and edges evaluated with breadth-first-search on the workflow graph from source nodes.

Parameters:

• sources (list[str], iterable) – Source nodes for the breadth-first-search. A container of nodes which will be iterated through once.
• reverse (bool, optional) – If True the workflow graph is assumed as reversed.
• add_missing (bool, optional) – If True, missing function’ inputs are added to the sub-dispatcher.
• check_inputs (bool, optional) – If True the missing function’ inputs are not checked.

Returns:

A sub-dispatcher.

Return type:

schedula.dispatcher.Dispatcher

pipe

Returns the full pipe of a dispatch run.