docs: def _add_node(self, node):
          """
          Add a node to the workflow
  
          :param node: The node object
          :type node: Node
          :return: None
          """
          self.nodes[node.node_id] = node
          logging.info("Added node with id {} containing {} streams".format(node.node_id, len(node.streams)))