Show progressbar when requeuing

main
zhangliyong 11 years ago
parent e1d236ec02
commit 36880db872

@ -47,14 +47,14 @@ def requeue():
"""Requeue all failed jobs in failed queue""" """Requeue all failed jobs in failed queue"""
failed_queue = get_failed_queue() failed_queue = get_failed_queue()
job_ids = failed_queue.job_ids job_ids = failed_queue.job_ids
click.echo('Requeuing {} failed jobs......'.format(len(job_ids))) click.echo('Requeue failed jobs: {}'.format(len(job_ids)))
requeue_failed_num = 0 requeue_failed_num = 0
for job_id in job_ids: with click.progressbar(job_ids) as job_bar:
for job_id in job_bar:
try: try:
failed_queue.requeue(job_id) failed_queue.requeue(job_id)
except InvalidJobOperationError: except InvalidJobOperationError:
click.echo('Requeue job({}) failed'.format(job_id))
requeue_failed_num += 1 requeue_failed_num += 1
click.secho('Requeue over with {} jobs requeuing failed'.format( click.secho('Requeue failed: {}'.format(
requeue_failed_num), fg='red') requeue_failed_num), fg='red')

Loading…
Cancel
Save