diff --git a/virttest/env_process.py b/virttest/env_process.py
index b6aefdaec75..869ed6e6e6d 100644
--- a/virttest/env_process.py
+++ b/virttest/env_process.py
@@ -869,16 +869,18 @@ def _call_check_image_func():
                     unpause_vm = True
                     vm_params['skip_cluster_leak_warn'] = "yes"
                 try:
-                    images = params.objects("images")
-                    _process_images_serial(
-                        check_image, test, images, vm_params,
-                        vm_process_status=vm_process_status)
+                    if params.get("drive_format") != "vdpa":
+                        images = params.objects("images")
+                        _process_images_serial(
+                            check_image, test, images, vm_params,
+                            vm_process_status=vm_process_status)
                 finally:
                     if unpause_vm:
                         vm.resume()
         else:
-            images = params.objects("images")
-            _process_images_serial(check_image, test, images, params)
+            if params.get("drive_format") != "vdpa":
+                images = params.objects("images")
+                _process_images_serial(check_image, test, images, params)
 
     # preprocess
     if not vm_first:
@@ -1379,7 +1381,8 @@ def preprocess(test, params, env):
                     params["cpu_driver"] = env.get("cpu_driver")
 
     # Preprocess all VMs and images
-    if params.get("not_preprocess", "no") == "no":
+    if params.get("not_preprocess", "no") == "no" and params.get(
+            "drive_format") != "vdpa":
         process(test, params, env, preprocess_image, preprocess_vm,
                 fs_source_func=preprocess_fs_source)
 
@@ -1553,8 +1556,9 @@ def postprocess(test, params, env):
                         " or install gcovr package for qemu coverage report")
     # Postprocess all VMs and images
     try:
-        process(test, params, env, postprocess_image,
-                postprocess_vm, True, postprocess_fs_source)
+        if params.get("drive") != "vdpa":
+            process(test, params, env, postprocess_image,
+                    postprocess_vm, True, postprocess_fs_source)
     except Exception as details:
         err += "\nPostprocess: %s" % str(details).replace('\\n', '\n  ')
         LOG.error(details)