diff --git a/client-cli/pvc/cli/waiters.py b/client-cli/pvc/cli/waiters.py index 6f2b4e02..93fefee4 100644 --- a/client-cli/pvc/cli/waiters.py +++ b/client-cli/pvc/cli/waiters.py @@ -79,7 +79,7 @@ def wait_for_celery_task(CLI_CONFIG, task_detail): # Wait for the task to start echo(CLI_CONFIG, "Waiting for task to start...", newline=False) while True: - sleep(0.25) + sleep(0.5) task_status = pvc.lib.common.task_status( CLI_CONFIG, task_id=task_id, is_watching=True ) @@ -104,7 +104,7 @@ def wait_for_celery_task(CLI_CONFIG, task_detail): newline=False, ) while True: - sleep(0.25) + sleep(0.5) if task_status.get("state") != "RUNNING": break if task_status.get("current") > last_task: diff --git a/daemon-common/celery.py b/daemon-common/celery.py index 547c11ef..08830a86 100644 --- a/daemon-common/celery.py +++ b/daemon-common/celery.py @@ -36,7 +36,7 @@ def start(celery, msg, current=0, total=1): celery.update_state( state="RUNNING", meta={"current": current, "total": total, "status": msg} ) - sleep(0.5) + sleep(1) def fail(celery, msg, current=1, total=1): @@ -67,7 +67,7 @@ def update(celery, msg, current=1, total=2): celery.update_state( state="RUNNING", meta={"current": current, "total": total, "status": msg} ) - sleep(0.5) + sleep(1) def finish(celery, msg, current=2, total=2): @@ -77,6 +77,6 @@ def finish(celery, msg, current=2, total=2): state="RUNNING", meta={"current": current, "total": total, "status": "Finishing up"}, ) - sleep(0.5) + sleep(1) logger.info(f"Success {current}/{total}: {msg}") return {"status": msg, "current": current, "total": total}