'Process queued signals.
Take one node node from the pending input queue and deliver
all scheduled signals.'

def process_queued(self, max_nodes=None):

    if (not ((max_nodes is None) or (max_nodes == 1))):
        warnings.warn('`max_nodes`    is    deprecated    and    unused    (will    always    equal    1)', DeprecationWarning, stacklevel=2)
    if (self.__runtime_state == SignalManager.Processing):
        raise RuntimeError("Cannot    re-enter    'process_queued'")
    if (not self._can_process()):
        raise RuntimeError(("Can't    process    in    state    %i" % self.__state))
    log.info('SignalManager:    Processing    queued    signals')
    node_update_front = self.node_update_front()
    log.debug('SignalManager:    Nodes    eligible    for    update    %s', [node.title for node in node_update_front])
    if node_update_front:
        node = node_update_front[0]
        self._set_runtime_state(SignalManager.Processing)
        try:
            self.process_node(node)
        finally:
            self._set_runtime_state(SignalManager.Waiting)
