def __call__(self, keep_rc=False):
        """
        Executes the pipeline.

        Returns:
            The final output of the pipeline if keep_rc is False;
            an (exit code, output) tuple if keep_rc is True.
        Raises:
            CalledProcessError if any return code in the pipeline is nonzero
            and keep_rc is False.
        """
        p = self._build_pipes()
        output = p.communicate()[0]
        rc = p.poll()
        if keep_rc:
            return (rc, output)
        if rc:
            raise CalledProcessError(rc, self.cmds[0], output)
        return output
def __call__ ( self , keep_rc = False ) : p = self . _build_pipes ( ) output = p . communicate ( ) [ 0 ] rc = p . poll ( ) if keep_rc : return ( rc , output ) if rc : raise CalledProcessError ( rc , self . cmds [ 0 ] , output ) return output
Executes the pipeline.

        Returns:
            The final output of the pipeline if keep_rc is False;
            an (exit code, output) tuple if keep_rc is True.
        Raises:
            CalledProcessError if any return code in the pipeline is nonzero
            and keep_rc is False.