def connect(cls, pipeline_method, name=None):
        """
        Low level logic to bind a callable method to a name.
        Don't call this directly unless you know what you are doing.

        :param pipeline_method: callable
        :param name: str optional
        :return: None
        """
        new_pool = pipeline_method().connection_pool
        try:
            if cls.get(name).connection_pool != new_pool:
                raise AlreadyConnected("can't change connection for %s" % name)
        except InvalidPipeline:
            pass

        cls.connections[name] = pipeline_method
def connect ( cls , pipeline_method , name = None ) : new_pool = pipeline_method ( ) . connection_pool try : if cls . get ( name ) . connection_pool != new_pool : raise AlreadyConnected ( "can't change connection for %s" % name ) except InvalidPipeline : pass cls . connections [ name ] = pipeline_method
Low level logic to bind a callable method to a name.
        Don't call this directly unless you know what you are doing.

        :param pipeline_method: callable
        :param name: str optional
        :return: None