dal.helpers.flow package

Submodules

dal.helpers.flow.gflow module

Copyright (C) Mov.ai - All Rights Reserved Unauthorized copying of this file, via any medium is strictly prohibited Proprietary and confidential

Developers: - Manuel Silva (manuel.silva@mov.ai) - 2020

class dal.helpers.flow.gflow.GFlow(flow)

Bases: object

Graph generator in use to calculate remaps

add_edge(key: str, _id: str, _type: str) → dict

Add a new edge to the vertex

calc_remaps() → dict

Returns the remaps after calculation

check_forced_links(port_type: str, link: Template) → str

check_ros_port(node_name: str, port_name: str)

function that verifies if a specific port name has a ROS message associated

Args:

node_name (str): simplified node name (e.g. publisher2) port_name (str): full port name (e.g. publisher2/bool_out/out)

Returns:

bool: True if port name has a ROS message associateds. False otherwise

flow: Flow

forced_remap(link: Template) → str

Special remap rules

generate_graph() → dict

Generate the graph

generate_remaps() → dict

Generates the remaps

get_adjacent_unremappable_port(port_type, links: list)

get_port_template(node_inst: str, port_name: str) → str

Get the port template from the node template

get_remaps(force: bool = False) → dict

Returns the calculated remaps

get_vertex(key: str, _type: str = 'From') → dict

Get or create a new vertex

iterate_through_links(port_type, links: list) → list

logger = <Logger gflow.mov.ai (INFO)>

reverse_type(port_type: str) → str

set_remap(key: str, remap: str)

Set the vertex remap value

should_skip(link: Template) → bool

Special rules for including vertex in the graph

sort_graph() → list

Sort the graph by the number of elements in links

Module contents

Copyright (C) Mov.ai - All Rights Reserved Unauthorized copying of this file, via any medium is strictly prohibited Proprietary and confidential

Developers: - Erez Zomer (erez@mov.ai) - 2022

class dal.helpers.flow.GFlow(flow)

Bases: object

Graph generator in use to calculate remaps

add_edge(key: str, _id: str, _type: str) → dict

Add a new edge to the vertex

calc_remaps() → dict

Returns the remaps after calculation

check_forced_links(port_type: str, link: Template) → str

check_ros_port(node_name: str, port_name: str)

function that verifies if a specific port name has a ROS message associated

Args:

node_name (str): simplified node name (e.g. publisher2) port_name (str): full port name (e.g. publisher2/bool_out/out)

Returns:

bool: True if port name has a ROS message associateds. False otherwise

flow: Flow

forced_remap(link: Template) → str

Special remap rules

generate_graph() → dict

Generate the graph

generate_remaps() → dict

Generates the remaps

get_adjacent_unremappable_port(port_type, links: list)

get_port_template(node_inst: str, port_name: str) → str

Get the port template from the node template

get_remaps(force: bool = False) → dict

Returns the calculated remaps

get_vertex(key: str, _type: str = 'From') → dict

Get or create a new vertex

iterate_through_links(port_type, links: list) → list

logger = <Logger gflow.mov.ai (INFO)>

reverse_type(port_type: str) → str

set_remap(key: str, remap: str)

Set the vertex remap value

should_skip(link: Template) → bool

Special rules for including vertex in the graph

sort_graph() → list

Sort the graph by the number of elements in links