def METHOD_NAME():
    """Harvest and index DAS datasets."""
    principal, kt = current_app.config['KRB_PRINCIPALS']['CADI']
    file_location = os.path.join(
        current_app.config['EXPERIMENTS_RESOURCES_LOCATION'], 'das.txt')
    @kinit(principal, kt)
    def _harvest_das_entries():
        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.')
    _harvest_das_entries()
    reindex_das_entries.delay()