<
>
legend
cluster_0
Data
cluster_1
Sub-dispatcher
cluster_2
Edges
cluster_3
Functions
cluster_4
Warnings and Errors
cluster_5
Special Nodes
1005
<data_id>(Data)
default
Default value.
initial_dist
Initial distance from `START` node.
wait_inputs
Wait all data estimations? `<bool>`
await_result
Wait async for function result? `<bool>`
distance
Distance from `START` node.
function
Process data function `data = f({"<node name>": data})`.
filter x
Filter function x used in the loop `for f in filters: data = f(data)`.
input_filter 0
Result of the function.
output_filter x
Result of filters[x](`input_filter x` | `output_filter x-1`).
remote parent x
Link to a node of the parent dispatcher.
remote child x
Link to a node ot a child dispatcher.
1024
Data node. The current one is a
sample showing the main attributes.
1005->1024
1006
<dispatcher_id>(Dispatcher)
await_domain
Wait async for domain result? `<bool>`
input_domain
Domain function `f(**inputs)`.
solution_domain
Domain function result.
weight
Distance weight coeff.
distance
Distance from `START` node.
1031
Sub-dispatcher node. It connects a given
dispatcher to the current one. The current
node one is a sample showing the main attributes.
1006->1031
1007->1017
<from> --> <to>
inp_id
Index of input args.
out_id
Index of output list.
weight
Edge distance.
This is an edge sample showing the main attributes.
1008
<function_id>(DispatchPipe)
1028
DispatchPipe node. It behaves like a
SubDispatchPipe node, but it overwrites
its solution.
1008->1028
1009
<function_id>(Function)
await_domain
Wait async for domain result? `<bool>`
await_result
Wait async for function result? `<bool>`
input_domain
Domain function `f(*inputs)`.
solution_domain
Domain function result.
weight
Distance weight coeff.
filter x
Filter function x used in the loop `for f in filters: output = f(output)`.
input_filter 0
Result of the function.
output_filter x
Result of filters[x](`input_filter x` | `output_filter x-1`).
distance
Distance from `START` node.
started
Execution started time.
duration
Time elapsed to execute the function.
1037
Function node. The current one is a
sample showing the main attributes.
1009->1037
1010
<function_id>(MapDispatch)
1040
MapDispatch node. It wraps and executes iteratively
a given Dispatcher into a function.
Hence, it behaves like a `map` function.
1010->1040
1011
<function_id>(SubDispatch)
1039
SubDispatch node. It wraps
a given Dispatcher into a function.
Inputs are dictionaries {<node_id>: <value>}.
1011->1039
1012
<function_id>(SubDispatchFunction)
1026
SubDispatchFunction node. It wraps and shrink
a given Dispatcher into a function.
Hence, it behaves like a function.
1012->1026
1013
<function_id>(SubDispatchPipe)
1027
SubDispatchPipe node. It wraps and compiles
a given Dispatcher into a function.
Hence, it behaves like a function.
1013->1027
1014
<function_id>(run_model)
1038
run_model node. It calls the first argument - i.e. the model.
If the model produces a the workflow, this is added to the
parent workflow.
First argument is a callable.
1014->1038
1015
<node_id>(Error)
error
Error message.
1029
Node that raised an error during its execution.
1015->1029
1016
<node_id>(Warning)
M_inputs
('missing inputs',)
M_outputs
('missing outputs',)
1030
Node that did not return all inputs/outputs.
1016->1030
1018
empty
1025
Empty dispatcher/workflow.
1018->1025
1019
end
1033
Ending node of SubDispatcherFunction.
It collects the function's outputs.
1019->1033
1020
plot
1036
Plot node. When invoked, it
plots the dispatcher solution.
1020->1036
1021
self
1035
Self node of the plotted dispatcher.
It represents the dispatcher as data node.
1021->1035
1022
sink
1034
Sink node. It collects
all unused outputs.
1022->1034
1023
start
1032
Starting node. It identifies
the initial inputs.
1023->1032