Function generate_msgs has a Cognitive Complexity of 56 (exceeds 5 allowed). Consider refactoring.

Open

def generate_msgs(
    source_Nc: Observable,
    rate_node: float,
    name: str,
    rate_in: float,

• Read up
  Read up

Function get_info has a Cognitive Complexity of 49 (exceeds 5 allowed). Consider refactoring.

Open

def get_info(cls, methods=None, no_cls=False, return_msg=False):
    """Get information on the entity's registered function"""
    REGISTRY = register.REGISTRY
    TYPE_REGISTER = register.TYPE_REGISTER

• Read up
  Read up

Function print_io_status has a Cognitive Complexity of 48 (exceeds 5 allowed). Consider refactoring.

Open

    def print_io_status(self, node_names=None):
        # Only print status for specific node
        if node_names is None:
            node_names = self.node_io.keys()
        else:

• Read up
  Read up

Function convert has a Cognitive Complexity of 39 (exceeds 5 allowed). Consider refactoring.

Open

def convert(space: eagerx.Space, processor, name, component, node, direction="out"):
    OUTPUT = True if direction == "out" else False
    INPUT = True if direction == "in" else False
    space_checked = [False]
    p_msg = f" (after processing with `{processor.__class__.__qualname__}`)" if processor else ""

• Read up
  Read up

Function initialize has a Cognitive Complexity of 39 (exceeds 5 allowed). Consider refactoring.

Open

    def initialize(self, spec_cls):
        import eagerx.core.register as register

        try:
            params = register.LOOKUP_TYPES[spec_cls.callback]

• Read up
  Read up

Function remap_cb_input has a Cognitive Complexity of 37 (exceeds 5 allowed). Consider refactoring.

Open

def remap_cb_input(mode=0):
    def _remap_cb_input(value):
        # mode=0 (info only), mode=1 (msgs only), mode=2 (all)
        if mode == 2:
            return value

• Read up
  Read up

Function regroup_inputs has a Cognitive Complexity of 30 (exceeds 5 allowed). Consider refactoring.

Open

def regroup_inputs(node, rate_node=1, is_input=True, perform_checks=True):
    node_name = node.ns_name
    color = node.color

    def _regroup_inputs(source):

• Read up
  Read up

Function connect_io has a Cognitive Complexity of 28 (exceeds 5 allowed). Consider refactoring.

Open

    def connect_io(self, print_status=True):
        # If log_level is not high enough, overwrite print_status
        if self.effective_log_level > DEBUG:
            print_status = False

• Read up
  Read up

Backend has 32 functions (exceeds 20 allowed). Consider refactoring.

Open

class Backend(Entity):
    """Baseclass for backends.

    Use this baseclass to implement backends that implement the communication.

Function throttle_with_time has a Cognitive Complexity of 25 (exceeds 5 allowed). Consider refactoring.

Open

def throttle_with_time(dt, node, rate_tol: float = 0.95, log_level: int = DEBUG):
    time_fn = lambda: time.monotonic_ns() / 1e9  # noqa: E731
    node_name = node.ns_name
    color = node.color
    effective_log_level = node.backend.log_level

• Read up
  Read up

Function add_rx_objects has a Cognitive Complexity of 25 (exceeds 5 allowed). Consider refactoring.

Open

    def add_rx_objects(
        self,
        node_name,
        node=None,
        inputs=tuple(),

• Read up
  Read up

Function _prepare_io_topics has a Cognitive Complexity of 25 (exceeds 5 allowed). Consider refactoring.

Open

    def _prepare_io_topics(self, name, **kwargs):
        params = get_param_with_blocking(name, self.backend)
        rate = params["config"]["rate"]

        # Get info on run-time settings

• Read up
  Read up

Function is_stale has a Cognitive Complexity of 24 (exceeds 5 allowed). Consider refactoring.

Open

def is_stale(G, exclude_skip=False):
    new_stale_nodes = [n for n, is_stale in nx.get_node_attributes(G, "is_stale").items() if is_stale]
    for n, data_n in G.nodes(data=True):
        # First, determine stale nodes, based on edges_in & always connected
        in_degree = G.in_degree(n)

• Read up
  Read up

Function trace_observable has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

def trace_observable(
    id: str,
    node,
    trace_next=False,
    trace_next_payload=False,

• Read up
  Read up

Function init_engine has 79 lines of code (exceeds 25 allowed). Consider refactoring.

Open

def init_engine(
    ns,
    rate_node,
    node,
    inputs_init,

Function _collect_args has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

def _collect_args(arg_str):
    """
    State-machine parser for resolve_args. Substitution args are of the form:
    $(find package_name)/scripts/foo.py $(export some/attribute blar) non-relevant stuff

• Read up
  Read up

Function callback has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

    def callback(self, t_n: float, **kwargs: Optional[Msg]):
        for name, i in kwargs.items():
            buffer = self.observation_buffer[name]
            window = buffer["window"]

• Read up
  Read up

Function convert_value has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

def convert_value(value, type_):
    """
    Convert a value from a string representation into the specified
    type

• Read up
  Read up

Function _prepare_io_topics has a Cognitive Complexity of 20 (exceeds 5 allowed). Consider refactoring.

Open

    def _prepare_io_topics(self, name):
        params = get_param_with_blocking(name, self.backend)
        node_names = params["config"]["node_names"]
        target_addresses = params["config"]["target_addresses"]
        rate = params["config"]["rate"]

• Read up
  Read up

Function remove has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

    def remove(self, names: Union[Union[str, EntitySpec], List[Union[str, EntitySpec]]]) -> None:
        """Removes a node from the graph.

        - First, all associated connections are disconnected.

• Read up
  Read up