def _compress(self, cmd):
        """Adds the appropriate command to compress the zfs stream"""
        compressor = COMPRESSORS.get(self.compressor)
        if compressor is None:
            return cmd
        compress_cmd = compressor['compress']
        return "{} | {}".format(compress_cmd, cmd)
def _compress ( self , cmd ) : compressor = COMPRESSORS . get ( self . compressor ) if compressor is None : return cmd compress_cmd = compressor [ 'compress' ] return "{} | {}" . format ( compress_cmd , cmd )
Adds the appropriate command to compress the zfs stream