diff --git a/tools/marvin/marvin/integration/lib/base.py b/tools/marvin/marvin/integration/lib/base.py
index 0daea5dd579..726a628d070 100644
--- a/tools/marvin/marvin/integration/lib/base.py
+++ b/tools/marvin/marvin/integration/lib/base.py
@@ -1109,6 +1109,9 @@ class DiskOffering:
         if domainid:
             cmd.domainid = domainid
 
+        if services["storagetype"]:
+            cmd.storagetype = services["storagetype"]
+
         return DiskOffering(apiclient.createDiskOffering(cmd).__dict__)
 
     def delete(self, apiclient):