@task
@runs_once
@requires_config(StandaloneConfig)
def logs():
    downloaded_logs_location = os.path.join(TMP_PRESTO_DEBUG, "logs")
    ensure_directory_exists(downloaded_logs_location)

    print 'Downloading logs from all the nodes...'
    execute(get_remote_log_files, downloaded_logs_location, roles=env.roles)

    copy_admin_log(downloaded_logs_location)

    make_tarfile(OUTPUT_FILENAME_FOR_LOGS, downloaded_logs_location)
    print 'logs archive created: ' + OUTPUT_FILENAME_FOR_LOGS
%prog ystr chrY.vcf
dataset/ETHPy150Open prestodb/presto-admin/prestoadmin/collect.py/logs--crossover with--dataset/ETHPy150Open tanghaibao/jcvi/variation/str.py/ystr