    def _get_node_queues(self):
        """
        Get node queue with given graph data queues.
        """
        node_queues = []
        for data_queue in self._data_queues:
            node_queue = {}
            for node in self._nodes.values():
                if node['name'] not in self._trace_nodes:
                    continue
                node_queue[node['name']] = {}
                node_queue[node['name']]['type'] = node['iter_info']['type']
                node_queue[node['name']]['operator'] = node['op_info']['operator']
                node_queue[node['name']]['in'] = [data_queue[edge] for edge in node['inputs']]
                node_queue[node['name']]['out'] = [data_queue[edge] for edge in node['outputs']]
                node_queue[node['name']]['op_input'] = node['op_input']
                node_queue[node['name']]['op_output'] = node['op_output']
                node_queue[node['name']]['next'] = [self._nodes[i]['name'] for i in node['next_nodes']]
            self._set_previous(node_queue)
            node_queues.append(node_queue)

        return node_queues
Get node queue with given graph data queues.
towhee/tools/visualizer.py