code: def get_connection_by_node(self, node):
          
          self._checkpid()
          self.nodes.set_node_name(node)
  
          try:
              # Try to get connection from existing pool
              connection = self._available_connections.get(node["name"], []).pop()
          except IndexError:
              connection = self.make_connection(node)
  
          self._in_use_connections.setdefault(node["name"], set()).add(connection)
  
          return connection
docs: get a connection by node