diff --git a/pkg/testutils/storageutils/mocking.go b/pkg/testutils/storageutils/mocking.go
index 52ab1012b147..4de75fb0b3e4 100644
--- a/pkg/testutils/storageutils/mocking.go
+++ b/pkg/testutils/storageutils/mocking.go
@@ -96,5 +96,8 @@ func (c *ReplayProtectionFilterWrapper) run(args kvserverbase.FilterArgs) *kvpb.
 	c.Unlock()
 
 	res := future.WaitForResult(args.Ctx)
+	if res.Err != nil {
+		return kvpb.NewError(res.Err)
+	}
 	return shallowCloneErrorWithTxn(res.Val.(*kvpb.Error))
 }