diff --git a/test/storage/recovery.result b/test/storage/recovery.result
index 05d9ccb8..6add2847 100644
--- a/test/storage/recovery.result
+++ b/test/storage/recovery.result
@@ -122,6 +122,9 @@ while _bucket:count() ~= 2 do vshard.storage.recovery_wakeup() fiber.sleep(0.1)
 _ = test_run:switch('storage_1_a')
 ---
 ...
+vshard.storage.internal.errinj.ERRINJ_RECOVERY_PAUSE = true
+---
+...
 _bucket:replace{1, vshard.consts.BUCKET.SENDING, util.replicasets[2]}
 ---
 - [1, 'sending', '<replicaset_2>']
diff --git a/test/storage/recovery.test.lua b/test/storage/recovery.test.lua
index 2a2a46f4..38852946 100644
--- a/test/storage/recovery.test.lua
+++ b/test/storage/recovery.test.lua
@@ -58,6 +58,7 @@ while _bucket:count() ~= 2 do vshard.storage.recovery_wakeup() fiber.sleep(0.1)
 -- must restore buckets, when the destination is up.
 --
 _ = test_run:switch('storage_1_a')
+vshard.storage.internal.errinj.ERRINJ_RECOVERY_PAUSE = true
 _bucket:replace{1, vshard.consts.BUCKET.SENDING, util.replicasets[2]}
 _ = test_run:switch('storage_2_a')
 _bucket:replace{1, vshard.consts.BUCKET.ACTIVE}