diff --git a/tests/integration/test_backup_restore_new/test.py b/tests/integration/test_backup_restore_new/test.py
index 869f36f194a..2ff5aeb4acf 100644
--- a/tests/integration/test_backup_restore_new/test.py
+++ b/tests/integration/test_backup_restore_new/test.py
@@ -278,7 +278,7 @@ def test_async():
     [id, _, status] = instance.query(
         f"BACKUP TABLE test.table TO {backup_name} ASYNC"
     ).split("\t")
-    assert status == "MAKING_BACKUP\n"
+    assert status == "MAKING_BACKUP\n" or status == "BACKUP_COMPLETE\n"
     assert_eq_with_retry(
         instance,
         f"SELECT status FROM system.backups WHERE uuid='{id}'",
@@ -290,7 +290,7 @@ def test_async():
     [id, _, status] = instance.query(
         f"RESTORE TABLE test.table FROM {backup_name} ASYNC"
     ).split("\t")
-    assert status == "RESTORING\n"
+    assert status == "RESTORING\n" or status == "RESTORED\n"
     assert_eq_with_retry(
         instance, f"SELECT status FROM system.backups WHERE uuid='{id}'", "RESTORED\n"
     )
diff --git a/tests/integration/test_backup_restore_on_cluster/test.py b/tests/integration/test_backup_restore_on_cluster/test.py
index 70dccd242c4..016e24780f5 100644
--- a/tests/integration/test_backup_restore_on_cluster/test.py
+++ b/tests/integration/test_backup_restore_on_cluster/test.py
@@ -389,7 +389,7 @@ def test_replicated_database_async():
         f"BACKUP DATABASE mydb ON CLUSTER 'cluster' TO {backup_name} ASYNC"
     ).split("\t")
 
-    assert status == "MAKING_BACKUP\n"
+    assert status == "MAKING_BACKUP\n" or status == "BACKUP_COMPLETE\n"
 
     assert_eq_with_retry(
         node1,
@@ -403,7 +403,7 @@ def test_replicated_database_async():
         f"RESTORE DATABASE mydb ON CLUSTER 'cluster' FROM {backup_name} ASYNC"
     ).split("\t")
 
-    assert status == "RESTORING\n"
+    assert status == "RESTORING\n" or status == "RESTORED\n"
 
     assert_eq_with_retry(
         node1, f"SELECT status FROM system.backups WHERE uuid='{id}'", "RESTORED\n"