def METHOD_NAME():
    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())  # to fix
    ip = socket.gethostbyname('lxplus.cern.ch')
    ssh.connect(ip,
                username='cernapcms',
                auth_timeout=100,
                look_for_keys=False,
                gss_auth=True)
    _, stdout, stderr = ssh.exec_command('sh ~/private/test.sh')
    if stdout.channel.recv_exit_status() != 0:
        current_app.logger.error(
            'DAS harvesting failed during generating GRID certificate.\n'
            '{}'.format(stderr.read()))
        raise DASHarvesterException
    query = "dataset status=*"
    cmd = 'export EOS_MGM_URL=root://eosmedia.cern.ch;' \
          't=$(mktemp);' \
          'eos cp {file_location} {file_location}.backup;' \
          'dasgoclient -query="{query}" > $t && ' \
          'eos cp $t {file_location}; out=$?;' \
          'rm -f $t;' \
          'exit $out;'.format(file_location=file_location, query=query)
    _, stdout, stderr = ssh.exec_command(cmd)
    if stdout.channel.recv_exit_status() != 0:
        current_app.logger.error(
            'DAS harvesting failed during querying DAS client.\n'
            '{}'.format(stderr.read()))
        raise DASHarvesterException
    current_app.logger.info('File with latest DAS entries saved.')