i6_core.rasr.flow

class i6_core.rasr.flow.FlagDependentFlowAttribute(flag, alternatives)
get(net)
class i6_core.rasr.flow.FlowNetwork(name='network')
Parameters:

name (str) –

add_flags(flags)
add_hidden_input(input)

in case a Path has to be converted to a string that is then added to the network

add_input(name)
add_net(net)
add_node(filter, name, attr=None, **kwargs)
add_output(name)
add_param(name)
apply_config(path, config, post_config)
contains_filter(filter_name)
default_flags = {}
get_input_ports()
get_node_names_by_filter(filter_name)
Parameters:

output_port (str) –

Returns:

list of from_name

Return type:

list[str]

get_output_ports()
interconnect(a, node_mapping_a, b, node_mapping_b, mapping=None)

assuming a and b are FlowNetworks that have already been added to this net, the outputs of a are linked to the inputs of b, optionally a mapping between the ports can be specified

interconnect_inputs(net, node_mapping, mapping=None)

assuming net has been added to self, link all of self’s inputs to net’s inputs, optionally a mapping between the ports can be specified

interconnect_outputs(net, node_mapping, mapping=None)

assuming net has been added to self, link all of net’s outputs to self’s outputs, optionally a mapping between the ports can be specified

Parameters:

  • from_name (str) –

  • to_name (str) –

remove_node(name)
subnet_from_node(node_name)

creates a new net where only nodes that follow the given node are retained. nodes before the specified node are not included. links between one retained node and one not retained one are returned aswell. this function is usefull if a part of a net should be duplicated without copying the other part

unique_name(name)
Parameters:

name (str) –

Return type:

str

write_to_file(file)
class i6_core.rasr.flow.NamedFlowAttribute(name, value)
get(net)
class i6_core.rasr.flow.NodeMapping(mapping)
Parameters:

mapping (dict) –

class i6_core.rasr.flow.PathWithPrefixFlowAttribute(prefix, path)
get(net)
class i6_core.rasr.flow.WriteFlowNetworkJob(*args, **kwargs)

Writes a flow network to a file

run()
tasks()
Returns:

yields Task’s

Return type:

list[sisyphus.task.Task]